fix cross thread cancel

Author: wokron

include/condy/runtime.hpp

@@ -277,6 +277,11 @@ class Runtime {
         tsan_release(&request);
         schedule_msg_ring_(curr_runtime,
                            encode_work(&request, WorkType::Cancel));
+        if (curr_runtime != nullptr) {
+            // Ensure the cancel msg is submitted.
+            curr_runtime->ring_.submit();
+            curr_runtime->resume_work();
+        }
         // Block until the runtime thread has submitted the cancel SQE. This is
         // important to prevent address reuse of the same data pointer, which
         // can lead to incorrect cancellation or other bugs.

tests/test_execution.cpp

@@ -104,4 +104,31 @@ TEST_CASE("test execution - when_any") {
 
     runtime.allow_exit();
     runtime_thread.join();
+}
+
+TEST_CASE("test execution - when_any with different thread") {
+    condy::Runtime runtime1, runtime2;
+    std::thread thread1([&] { runtime1.run(); });
+    std::thread thread2([&] { runtime2.run(); });
+
+    auto scheduler1 = condy::get_scheduler(runtime1);
+    auto scheduler2 = condy::get_scheduler(runtime2);
+
+    __kernel_timespec ts = {
+        .tv_sec = 60ll * 60ll,
+        .tv_nsec = 0,
+    };
+    auto sender1 =
+        ex::schedule(scheduler1) | ex::let_value([&] {
+            return condy::detail::as_sender(condy::async_timeout(&ts, 0, 0));
+        });
+    auto sender2 = ex::schedule(scheduler2) | ex::then([] { return 42; });
+    auto when_any_sender = exec::when_any(sender1, sender2);
+    auto [r] = ex::sync_wait(when_any_sender).value();
+    REQUIRE(r == 42);
+
+    runtime1.allow_exit();
+    runtime2.allow_exit();
+    thread1.join();
+    thread2.join();
 }