Closed thomasst closed 4 months ago
Analyzing the thread safety of the heartbeat function in the sync executor:
single_connection_client
heartbeat()
Semaphore
thread_local=False
Also:
Analyzing the thread safety of the heartbeat function in the sync executor:
single_connection_client
is given, which is false by default.heartbeat()
we update the task timestamp, renew any task locks and any queue lock.Semaphore
) does not care about threads so we can therefore renew it from a different thread.thread_local=False
.Also: