-
Notifications
You must be signed in to change notification settings - Fork 2
/
PingPongProcess.php
49 lines (37 loc) · 1.11 KB
/
PingPongProcess.php
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
<?php
use ParallelLibrary\ParallelProcess;
use ParallelLibrary\interfaces\IMessage;
use ParallelLibrary\Message;
class PingPongProcess extends ParallelProcess
{
const MESSAGE_TYPE_PING = 'PING';
const MESSAGE_TYPE_PONG = 'PONG';
const MESSAGE_TYPE_TIRED = "I am tired, let's stop";
private $currentCount;
private $maxCount;
public function run($arguments)
{
$this->currentCount = 0;
$this->maxCount = rand(1, 10);
$this->playPingPong();
}
private function playPingPong()
{
while ($this->currentCount < $this->maxCount) {
$this->processMessages();
}
$this->sendMessage(new Message(self::MESSAGE_TYPE_TIRED));
}
public function handleMessage(IMessage $message)
{
switch ($message->type) {
case self::MESSAGE_TYPE_PING:
sleep(1);
$this->currentCount++;
$this->sendMessage(new Message(self::MESSAGE_TYPE_PONG));
break;
default:
break;
}
}
}