38a3316336
- Implemented pre-acquisition of execution slots in the Tick method to prevent race conditions, ensuring that robots do not submit duplicate executions. - Updated TryAcquireSlot method to support idempotent behavior, allowing for early slot reservation without consuming additional resources. - Modified worker execution logic to skip pre-checks for robots that have already acquired a slot, streamlining the execution process. - Improved error handling during execution submission to ensure proper tracking and removal of failed executions. |
||
|---|---|---|
| .. | ||
| goroutine_test.go | ||
| pool.go | ||
| pool_test.go | ||
| queue.go | ||
| queue_test.go | ||
| worker.go | ||
| worker_test.go | ||