diff --git a/src/Worker.php b/src/Worker.php index 8b58e5f9..b39f793a 100644 --- a/src/Worker.php +++ b/src/Worker.php @@ -64,6 +64,9 @@ if (!extension_loaded('pthreads')) { private function runCollectable($idx, Collectable $collectable) { $collectable->worker = $this; + if (!isset($collectable->state)) { + $collectable->state = 0; + } $collectable->state |= THREAD::RUNNING; $collectable->run(); $collectable->state &= ~THREAD::RUNNING;