Function initPHPThreads

phpmainthread.go:37–78

initPHPThreads starts the main PHP thread, a fixed number of inactive PHP threads and reserves a fixed number of possible PHP threads

(numThreads int, numMaxThreads int, phpIni map[string]string)

// a fixed number of inactive PHP threads
// and reserves a fixed number of possible PHP threads
func initPHPThreads(numThreads int, numMaxThreads int, phpIni map[string]string) (*phpMainThread, error) {
	mainThread = &phpMainThread{
		state:      state.NewThreadState(),
		done:       make(chan struct{}),
		numThreads: numThreads,
		maxThreads: numMaxThreads,
		phpIni:     phpIni,
	}

	// initialize the first thread
	// this needs to happen before starting the main thread
	// since some extensions access environment variables on startup
	// the threadIndex on the main thread defaults to 0 -> phpThreads[0].Pin(...)
	initialThread := newPHPThread(0)
	phpThreads = []*phpThread{initialThread}

	if err := mainThread.start(); err != nil {
		return nil, err
	}

	// Must follow start(): maxThreads is only final once
	// setAutomaticMaxThreads runs on the main PHP thread (before Ready).
	C.frankenphp_init_thread_metrics(C.int(mainThread.maxThreads))

	// initialize all other threads
	phpThreads = make([]*phpThread, mainThread.maxThreads)
	phpThreads[0] = initialThread
	for i := 1; i < mainThread.maxThreads; i++ {
		phpThreads[i] = newPHPThread(i)
	}

	// start the underlying C threads
	var ready sync.WaitGroup

	for i := 0; i < numThreads; i++ {
		ready.Go(phpThreads[i].boot)
	}

	ready.Wait()

	return mainThread, nil
}

func drainPHPThreads() {
	if mainThread == nil {