Fix memory leak when canceling tasks

src/base/task_runner.h

@@ -18,16 +18,15 @@ namespace internal {
 // one that returns via an output parameter.
 template <typename ReturnType>
 void ReturnAsParamAdapter(std::function<ReturnType()> func,
-                          ReturnType* result) {
+                          std::shared_ptr<ReturnType> result) {
   *result = func();
 }
 
 // Adapts a ReturnType* result to a callblack that expects a ReturnType.
 template <typename ReturnType>
 void ReplyAdapter(std::function<void(ReturnType)> callback,
-                  ReturnType* result) {
+                  std::shared_ptr<ReturnType> result) {
   callback(std::move(*result));
-  delete result;
 }
 
 }  // namespace internal
@@ -57,13 +56,20 @@ class TaskRunner {
                                   std::function<ReturnType()> task,
                                   std::function<void(ReturnType)> reply,
                                   bool front = false) {
-    auto* result = new ReturnType;
+    auto result = std::make_shared<ReturnType>();
     return PostTaskAndReply(
         from,
         std::bind(internal::ReturnAsParamAdapter<ReturnType>, std::move(task),
                   result),
-        std::bind(internal::ReplyAdapter<ReturnType>, std::move(reply),
+        std::bind(internal::ReplyAdapter<ReturnType>, std::move(reply), result),
-                  result), front);
+        front);
+  }
+
+  // Posts a task to delete the given object.
+  template <class T>
+  void Delete(Location from, std::unique_ptr<T> object) {
+    std::shared_ptr<T> owned = std::move(object);
+    PostTask(HERE, [owned]() {});
   }
 
   void CancelTasks();

src/engine/renderer/vulkan/renderer_vulkan.cc

@@ -414,10 +414,7 @@ uint64_t RendererVulkan::CreateGeometry(std::unique_ptr<Mesh> mesh) {
                                   VK_PIPELINE_STAGE_VERTEX_INPUT_BIT,
                                   VK_ACCESS_TRANSFER_WRITE_BIT,
                                   VK_ACCESS_VERTEX_ATTRIBUTE_READ_BIT));
-  task_runner_.PostTask(HERE, [&, mesh = mesh.release()]() {
+  task_runner_.Delete(HERE, std::move(mesh));
-    // Transfer mesh ownership to the background thread.
-    std::unique_ptr<Mesh> own(mesh);
-  });
   semaphore_.release();
 
   return last_resource_id_;
@@ -506,10 +503,7 @@ void RendererVulkan::UpdateTexture(uint64_t resource_id,
                 0, VK_ACCESS_SHADER_READ_BIT,
                 VK_IMAGE_LAYOUT_TRANSFER_DST_OPTIMAL,
                 VK_IMAGE_LAYOUT_SHADER_READ_ONLY_OPTIMAL));
-  task_runner_.PostTask(HERE, [&, image = image.release()]() {
+  task_runner_.Delete(HERE, std::move(image));
-    // Transfer image ownership to the background thread.
-    std::unique_ptr<Image> own(image);
-  });
   semaphore_.release();
 }