danog/parallel
1
0
Fork 0
mirror of https://github.com/danog/parallel.git synced 2025-01-22 14:01:14 +01:00
Code Issues Projects Releases Wiki Activity

Add checks to fix #3 on thread creation

Browse Source
This commit is contained in:
coderstephen 2015-08-27 15:32:57 -05:00
parent c368bd140c
commit 4a029630a0
1 changed files with 9 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

10
src/Threading/Thread.php
View File

@ -66,6 +66,14 @@ class Thread implements ContextInterface, SynchronizableInterface
{
$args = array_slice(func_get_args(), 1);
// Make sure closures don't `use` other variables or have statics.
if ($function instanceof \Closure) {
$reflector = new \ReflectionFunction($function);
if (!empty($reflector->getStaticVariables())) {
throw new InvalidArgumentError('Closures with static variables cannot be passed to thread.');
}
}
list($channel, $this->socket) = Channel::createSocketPair();
$this->thread = new InternalThread($this->socket, $function, $args);
@ -116,7 +124,7 @@ class Thread implements ContextInterface, SynchronizableInterface
*
* @resolve mixed Resolved with the return or resolution value of the context once it has completed execution.
*
* @throws \Icicle\Concurrent\Exception\StatusError Thrown if the context has not been started.
* @throws \Icicle\Concurrent\Exception\StatusError Thrown if the context has not been started.
* @throws \Icicle\Concurrent\Exception\SynchronizationError Thrown if an exit status object is not received.
*/
public function join()