Serialize tasks running on the same stream. Ensure that a task is run with the currently available running state - either from memory or from state store. This makes a task code simpler.
Wait till the tasks are done, and prohibit adding more tasks.
Return execution lane for a stream.
Wait till all the tasks in all the lanes are done.
Stop executing the tasks.