Hi, I’m a bit confused as to what the documentation means by make sure to do an asynchronous drain on the Signal channel. Is the following an async drain? If not, what should I be doing? func SimpleWorkflow(ctx workflow.Context) error { workflow.Go(ctx, func(ctx workflow.Context) { var signal…

Oh… I see. So if I had several of signal receivers in various workflow.Go functions, then I would need to stop them and then do a ReceiveAsync on each receiver not in a workflow.Go function before exiting?

There is no even need to stop them as they are guaranteed not to run while the main workflow goroutine is executing.

Interesting. I must have missed that in the documentation. Sorry for the tangent… let’s say that there are two workflow.Go routines, can they run in parallel or does Temporal limit the workflow to only one active task at one time?

Workflow code must be deterministic. The only way to run code that contains multiple goroutines is to use cooperative multi-threading. This means that only one goroutine per workflow runs at a time. When it blocks on some Temporal API like Sleep or Fugure.Get the control is passed back to Temporal S…

Thank you! This was super enlightening.

[image] maxim: There is no even need to stop them as they are guaranteed not to run while the main workflow goroutine is executing. I missed one edge case. If there is a goroutine blocked on Channel.Receive. Then a new message can be allocated to that call (even if its goroutine never wakes u…

Async Drain Signals?

Community Support

tihomir February 16, 2023, 9:56pm 2

Take a look at post here for sample code impl (use of ReceiveAsync).

Topic		Replies	Views
Can a workflow receive signals more than once? Community Support go-sdk	5	1645	June 28, 2023
ContinueAsNew + signals Community Support go-sdk	36	8218	November 15, 2022
AsyncReceive to prevent signal loss Developer Corner	3	74	March 12, 2025
Send and receive signals in parallel Community Support go-sdk	1	592	May 9, 2023
What Guarantees Exist (If Any) for Draining Signals? Community Support go-sdk	1	339	December 10, 2023

Async Drain Signals?

Related topics