@ 2015-10-10T00:19:32Z <?php
class Operation
{
protected $routine;
protected $promise;
public function __construct(\Closure $routine, $promise)
{
$this->routine = $routine;
$this->promise = $promise;
}
public function run()
{
$routine = $this->routine();
$routine($this->promise);
}
public function getPromise()
{
return $this->promise;
}
}
class Promise
{
protected $successClosure;
protected $failClosure;
public function fulfill(...$args)
{
$closure = $this->successClosure;
$closure(...$args);
}
public function reject(...$args)
{
$closure = $this->failClosure;
$closure(...$args);
}
public function then(\Closure $success, \Closure $fail)
{
$this->successClosure = $success;
$this->failClosure = $fail;
}
}
class Queue
{
protected $queue = [];
public function append(Operation $operation) {
$this->queue[] = $operation;
}
public function getOperationGenerator()
{
foreach ($this->queue as $operation) {
yield $operation;
}
}
}
class QueueHandler
{
protected $queues = [];
public function addQueue($handle, Queue $queue)
{
$this->queues[$handle] = $queue;
}
public function getQueue($handle, $defualt=null)
{
return isset($this->queues[$handle]) ? $this->queues[$handle] : $default;
}
protected function getOperationGenerator()
{
$queues = [];
foreach ($this->queues as $queue) {
$queues[] = $queue->getOperationGenerator();
}
foreach ($queues as $queue) {
yield from $queue;
}
}
protected function getRunGenerator()
{
$operation_generator = $this->getOperationGenerator();
foreach ($operation_generator as $operation) {
yield $operation;
}
}
public function run() {
$generator = $this->getRunGenerator();
foreach ($generator as $operation) {
$operation->run();
}
}
}
function addOperation(\Closure $routine, Queue $queue) {
$promise = new Promise();
$operation = new Operation($routine, $promise);
$queue->append($operation);
return $promise;
}
$queue_handler = new QueueHandler();
$queue_handler->addQueue('main', new Queue());
$queue_handler->addQueue('secondary', new Queue());
$runtime = function(Promise $promise) use ($queue_handler) {
$handle_request = function(Promise $promise) {
var_dump('handled request');
$promise->fulfill();
};
$request_promise = addOperation($handle_request, $queue_handler->getQueue('secondary'));
$request_promise->then(function() {
die('Regular shutdown');
}, function() {
die('Error!');
});
};
addOperation($runtime, $queue_handler->getQueue('main'));
$queue_handler->run();
Enable javascript to submit You have javascript disabled. You will not be able to edit any code.
Output for 7.0.0 - 7.0.20 , 7.1.0 - 7.1.20 , 7.2.0 - 7.2.33 , 7.3.16 - 7.3.33 , 7.4.0 - 7.4.33 , 8.0.0 - 8.0.30 , 8.1.0 - 8.1.28 , 8.2.0 - 8.2.18 , 8.3.0 - 8.3.6 Fatal error: Uncaught Error: Call to undefined method Operation::routine() in /in/28cCX:18
Stack trace:
#0 /in/28cCX(115): Operation->run()
#1 /in/28cCX(149): QueueHandler->run()
#2 {main}
thrown in /in/28cCX on line 18
Process exited with code 255 . Output for 5.6.8 - 5.6.28 Parse error: syntax error, unexpected '$queue' (T_VARIABLE) in /in/28cCX on line 97
Process exited with code 255 . Output for 5.4.2 - 5.4.45 , 5.5.24 - 5.5.35 Parse error: syntax error, unexpected '.', expecting '&' or variable (T_VARIABLE) in /in/28cCX on line 36
Process exited with code 255 . preferences:dark mode live preview
151.5 ms | 402 KiB | 226 Q