code: public function onProcessCreate(Semaphore $semaphore) {
  		$this->semaphore = $semaphore;
  		$this->create->__invoke($this->semaphore, $this->storage);
  	}
docs: 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