Function DrainWorkers

worker.go:174–176

EXPERIMENTAL: DrainWorkers initiates a graceful drain of all worker scripts. Blocks until every drained thread yields. Force-kill is armed after a grace period to wake threads parked in blocking syscalls (sleep, I/O).

()

// Blocks until every drained thread yields. Force-kill is armed after a
// grace period to wake threads parked in blocking syscalls (sleep, I/O).
func DrainWorkers() {
	_ = drainWorkerThreads()
}

func drainWorkerThreads() (drainedThreads []*phpThread) {
	var ready sync.WaitGroup