Commit835089c

committed

[Process] Add support for Fiber

1 parentff70bd1 commit835089cCopy full SHA for 835089c

File tree

+17

-2

lines changed

+17

-2

lines changed

Lines changed: 5 additions & 0 deletions

Lines changed: 12 additions & 2 deletions

Original file line number	Diff line number	Diff line change
`@@ -427,12 +427,22 @@ public function wait(callable $callback = null)`
`427`	`427`	`do {`
`428`	`428`	`$this->checkTimeout();`
`429`	`429`	`$running ='\\' === \DIRECTORY_SEPARATOR ?$this->isRunning() :$this->processPipes->areOpen();`
`430`		`-$this->readPipes($running,'\\' !== \DIRECTORY_SEPARATOR \|\| !$running);`
	`430`	`+`
	`431`	`+if (\PHP_VERSION_ID >=80100 && \Fiber::getCurrent()) {`
	`432`	`+$this->readPipes(false,'\\' !== \DIRECTORY_SEPARATOR \|\| !$running);`
	`433`	`+ \Fiber::suspend();`
	`434`	`+ }else {`
	`435`	`+$this->readPipes($running,'\\' !== \DIRECTORY_SEPARATOR \|\| !$running);`
	`436`	`+ }`
`431`	`437`	`}while ($running);`
`432`	`438`
`433`	`439`	`while ($this->isRunning()) {`
`434`	`440`	`$this->checkTimeout();`
`435`		`-usleep(1000);`
	`441`	`+if (\PHP_VERSION_ID >=80100 && \Fiber::getCurrent()) {`
	`442`	`+ \Fiber::suspend();`
	`443`	`+ }else {`
	`444`	`+usleep(1000);`
	`445`	`+ }`
`436`	`446`	`}`
`437`	`447`
`438`	`448`	`if ($this->processInformation['signaled'] &&$this->processInformation['termsig'] !==$this->latestSignal) {`

Comments

(0)