src/SuperClosureWorker.php
public function onProcessCreate(Semaphore $semaphore) {
		$this->semaphore = $semaphore;
		$this->create->__invoke($this->semaphore, $this->storage);
	}
public function onProcessCreate(Semaphore $semaphore) {
		$this->semaphore = $semaphore;
		$this->create->__invoke($this->semaphore, $this->storage);
	}
After the worker has been forked into another process

@param \QXS\WorkerPool\Semaphore $semaphore the semaphore to run synchronized tasks
@throws \Exception in case of a processing Error an Exception will be thrown