(PECL pthreads >= 2.0.0)
Threaded::synchronized — Synchronization
Executes the block while retaining the referenced objects synchronization lock for the calling context
blockThe block of code to execute
...Variable length list of arguments to use as function arguments to the block
The return value from the block
Example #1 Synchronizing
<?php
class My extends Thread {
public function run() {
$this->synchronized(function($thread){
if (!$thread->done)
$thread->wait();
}, $this);
}
}
$my = new My();
$my->start();
$my->synchronized(function($thread){
$thread->done = true;
$thread->notify();
}, $my);
var_dump($my->join());
?>
The above example will output:
bool(true)
Threaded::synchronized() allows you to safely set or read synchronization conditions and act upon them (using ::wait() and ::notify()) knowing that only one call to synchronized() on the referenced object can be executed at a particular time, other calls from different thread contexts will block until the path is cleared by a call to ::wait() inside your ::Synchronized() closure.
