add worker cancellation test (failing)

1 files changed, 27 insertions, 0 deletions

diff --git a/test/miscellaneous/worker.cpp b/test/miscellaneous/worker.cpp
index 50fabcebc8..de0654422c 100644
--- a/test/miscellaneous/worker.cpp
+++ b/test/miscellaneous/worker.cpp
@@ -68,3 +68,30 @@ TEST(Worker, WorkRequestJoinCancelsAfter) {
     uv_run(uv_default_loop(), UV_RUN_DEFAULT);
     EXPECT_FALSE(didAfter);
 }
+
+TEST(Worker, WorkRequestCancelsImmediately) {
+    RunLoop loop(uv_default_loop());
+
+    Worker worker(1);
+
+    loop.invoke([&] {
+        std::promise<void> started;
+        // First worker item.
+        WorkRequest request1 = worker.send([&] {
+            usleep(10000);
+            started.set_value();
+        }, [&] {});
+
+        WorkRequest request2 = worker.send([&] {
+            ADD_FAILURE() << "Second work item should not be invoked";
+        }, [&] {});
+        request2.join();
+
+        started.get_future().get();
+        request1.join();
+
+        loop.stop();
+    });
+
+    uv_run(uv_default_loop(), UV_RUN_DEFAULT);
+}