executorservice/testExecutorService.php at master · appserver-io-lab/executorservice · GitHub

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
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
<?php

require('ExecutorService.php');

class SingletonSessionBean {

    public function __construct() {
        $this->array = array();
    }

    /**
     * Sets an value for specific key
     *
     * @param string $key
     * @param mixed $value
     *
     * @return void
     * @Synchronized
     */
    public function set($key, $value) {
        $this->data[$key] = $value;
    }

    /**
     * Returns value for specific key
     *
     * @param string $key
     *
     * @return mixed
     * @Synchronized
     */
    public function get($key) {
        return $this->data[$key];
    }

    /**
     * Do something example function
     *
     * @return void
     * @Synchronized
     */
    public function doSomething() {
        $this->array["bla"] = array(
            "foo" => "bar"
        );
        $this->arrayObj = new \ArrayObject($this->array);
    }

    /**
     * Async example function
     *
     * @return void
     * @Asynchronous
     */
    public function doAwesome($a, $b) {
        echo "begin : " . __METHOD__ . PHP_EOL;
        usleep(1000000);
        $user = new \stdClass();
        $user->name = $a. $b;
        echo "end : " . __METHOD__ . PHP_EOL;
        return $user;
    }
}

class Request extends \Thread
{
    public function __construct() {
        $this->start(PTHREADS_INHERIT_ALL | PTHREADS_ALLOW_GLOBALS);
    }

    public function run()
    {
        $session = \AppserverIo\Lab\ExecutorService::__getEntity('session');
        $session->doSomething();
        $session->set('ThreadId:' . $this->getThreadId(), $this->getThreadId());
    }
}

class TestThread extends \Thread
{
    public function run()
    {
        $session = \AppserverIo\Lab\ExecutorService::__newFromEntity('\SingletonSessionBean', 'session');
        usleep(2000000);
        var_dump($session->__return());
    }
}

\AppserverIo\Lab\ExecutorService::__init();

$entity = \AppserverIo\Lab\ExecutorService::__newFromEntity('\SingletonSessionBean');

$t = new \TestThread();
$t->start(PTHREADS_INHERIT_ALL | PTHREADS_ALLOW_GLOBALS);

$entity->doAwesome('FOO', 'BAR');
$entity->doSomething();

var_dump($entity->__return());

$entity->__reset();

var_dump($entity->__return());

$entity->doSomething();

var_dump($entity->__return());
$entity->doAwesome('FOO', 'BAR')->__callback(function($x) { echo 'CALLBACK!' . PHP_EOL; });

$maxr = 100;
$r = array();
for ($i = 1; $i <= $maxr; $i++) {
    $r[$i] = new \Request();
}
for ($i = 1; $i <= $maxr; $i++) {
    $r[$i]->join();
}

$session = \AppserverIo\Lab\ExecutorService::__getEntity('session');
$session->doSomething();

echo "finished script" . PHP_EOL;

$t->join();

while(1) {
    usleep(1000000);
}