little

.github/workflows/go.yml

@@ -14,10 +14,10 @@ jobs:
     strategy:
       matrix:
         os: ["ubuntu-latest", "macos-latest", "windows-latest"]
-        go-ver: ["1.21", "1.20", "1.19"]
+        go-ver: ["1.22", "1.21", "1.20", "1.19"]
         include:
           - os: "ubuntu-latest"
-            go-ver: "1.21"
+            go-ver: "1.22"
             cover: true
 
     runs-on: ${{ matrix.os }}

batch4.go

@@ -85,6 +85,7 @@ func (c *Coordinator[Res]) Notify() {
 // It returns index of entered worker.
 // 0 means we are the first and we should reset the shared state.
 // If blocking == false and batch is not available negative value returned.
+// Enter also removes worker from the queue.
 func (c *Coordinator[Res]) Enter(blocking bool) int {
 	c.mu.Lock()
 

doc.go

@@ -20,13 +20,13 @@ Logic for Coordinator
 Workers are distributed among multiple coaches and then each coach works the same as in Coordinator case.
 
 	                    -------------------------
-	              | -> | state is combined in a  |            /--> worker0
-	-> worker0 -> | -> | few independent coaches | -> result  ---> worker1
+	              | -> | workers are ditributed  |            /--> worker0
+	-> worker0 -> | -> | among free coaches      | -> result  ---> worker1
 	-> worker1 -> |     -------------------------
 	-> worker2 -> |
 	-> worker3 -> |     -------------------------
-	              | -> | each is committed as an |            /--> worker2
-	              | -> | independent part        | -> result  ---> worker3
+	              | -> | state is combined in a  |            /--> worker2
+	              | -> | few independent coaches | -> result  ---> worker3
 	                    -------------------------
 
 Full Guide

multi.go

@@ -56,6 +56,9 @@ func (c *Multi[Res]) Notify() {
 
 // Enter enters available batch.
 // It will return -1, -1 if no coaches available and blocking == false.
+// Enter also removes worker from the queue.
+//
+// See also documentation for Coordinator.Enter.
 //
 // coach choice can be configured by setting custom Multi.Balancer.
 func (c *Multi[Res]) Enter(blocking bool) (coach, idx int) {