feat: add task API for bidirectional background worker communication

Author: nicolas-grekas

background_worker.go

@@ -130,9 +130,9 @@ func buildBackgroundWorkerLookups(workers []*worker, opts []workerOpt) map[strin
 		workers[i].backgroundScope = scope
 
 		w := workers[i]
-		if w.name != "" && w.name != w.fileName {
-			// Named background worker; strip m# prefix so PHP sees the clean name
-			phpName := strings.TrimPrefix(w.name, "m#")
+		phpName := strings.TrimPrefix(w.name, "m#")
+		if phpName != "" && phpName != w.fileName {
+			// Named background worker
 			if o.num > 0 {
 				registry.AddAutoStartNames(phpName)
 				registry.SetNum(o.num)
@@ -172,6 +172,8 @@ func (registry *backgroundWorkerRegistry) reserve(name string) (*backgroundWorke
 
 	bgw := &backgroundWorkerState{
 		ready: make(chan struct{}),
+		tasks: make(chan *taskRequest, 1), // buffer=1: backpressure with signaling
+		dead:  make(chan struct{}),
 	}
 	registry.workers[name] = bgw
 
@@ -185,6 +187,9 @@ func (registry *backgroundWorkerRegistry) remove(name string, bgw *backgroundWor
 	if registry.workers[name] == bgw {
 		delete(registry.workers, name)
 	}
+
+	// Signal waiting senders that this worker is gone
+	bgw.deadOnce.Do(func() { close(bgw.dead) })
 }
 
 func startBackgroundWorker(thread *phpThread, bgWorkerName string) error {
@@ -234,6 +239,7 @@ func startBackgroundWorkerWithRegistry(registry *backgroundWorkerRegistry, bgWor
 	worker.isBackgroundWorker = true
 	worker.backgroundWorker = bgw
 	worker.backgroundRegistry = registry
+	bgw.fds = &worker.backgroundFds
 
 	for i := 0; i < numThreads; i++ {
 		bgWorkerThread := getInactivePHPThread()