async atomic notification of stop condition

1 files changed, 10 insertions, 0 deletions

diff --git a/lib/block_task.cpp b/lib/block_task.cpp
index 7f40f47..0af7cb1 100644
--- a/lib/block_task.cpp
+++ b/lib/block_task.cpp
@@ -113,6 +113,16 @@ void BlockActor::handle_task(void)
         this->output_queues.all_ready()
     )) return;
 
+    //------------------------------------------------------------------
+    //-- Asynchronous notification through atomic variable
+    //-- that the executor has instructed workers to stop.
+    //------------------------------------------------------------------
+    if (active_token.expired())
+    {
+        this->mark_done();
+        return;
+    }
+
     const size_t num_inputs = this->get_num_inputs();
     const size_t num_outputs = this->get_num_outputs();