more index work

040-worker-pools/worker-pools.go

@@ -0,0 +1,31 @@
+// ## Worker Pools
+
+package main
+
+import "time"
+
+func main() {
+    jobs := make(chan int, 100)
+    acks := make(chan bool, 100)
+
+    for w := 0; w < 10; w++ {
+        go func() {
+            for j := range jobs {
+                println("worker", w, "processing job", j)
+                time.Sleep(time.Millisecond * 150)
+                acks <- true
+            }
+        }()
+    }
+
+    for j := 0; j < 100; j++ {
+        jobs <- j
+    }
+
+    for a := 0; a < 100; a++ {
+        <-acks
+    }
+    println("all done")
+}
+
+// todo: broken