executorservice/testExecutorServicePromises.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
<?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];
    }

    /**
     * Returns object itself
     *
     * @return SingletonSessionBean
     */
    public function dump()
    {
        return $this;
    }

    /**
     * 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()
    {
        $bean = ExecutorService::__getInstance();
        $bean->doSomething();
        $bean->set('ThreadId:' . $this->getThreadId(), md5(time()));
    }

}
$bean = ExecutorService::__init('\SingletonSessionBean');

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

$bean->set('testKey', 'testValue');
var_dump($bean->get('testKey'));

$bean->doAwesome('David', 'Test')
->__then(function($user) use ($bean) {
    echo "Amazing Callback 1111!" . PHP_EOL;
})
->__then(function($x) {
    echo "Amazing Callback 2222!" . PHP_EOL;
})
->__then(function($x) {
    echo "Amazing Callback 3333!" . PHP_EOL;
});

echo 'finished script' . PHP_EOL;

var_dump($bean->get('testKey'));

while(1) {
    usleep(1000000);
}