@@ -27,22 +27,19 @@ class TaskTest extends UnitTest
27
27
28
28
public function testTasksWork ()
29
29
{
30
- echo "enter taskTest \n" ;
31
- $ this ->initTask ();
32
30
self ::$ nTasks ++;
33
- echo self ::$ nTasks , "\n" ;
34
- $ this ->taskCounter ++;
35
- $ this ->eventChain ->before ('test_task_num_ ' . $ this ->taskCounter , 'test_task_done ' );
36
-
37
- $ this ->scanTasks ();
38
- $ taskCoroutine = $ this ->runTaskTests ();
39
-
40
- self ::$ jobs [] = $ taskCoroutine ;
31
+ self ::$ jobs [] = $ this ;
41
32
42
33
if (self ::$ isRunningJob ) {
43
34
return ;
44
35
}
45
- $ taskCoroutine = array_shift (self ::$ jobs );
36
+
37
+ $ task = array_shift (self ::$ jobs );
38
+ $ task ->initTask ();
39
+ $ task ->taskCounter ++;
40
+ $ task ->eventChain ->before ('test_task_num_ ' . $ task ->taskCounter , 'test_task_done ' );
41
+ $ task ->scanTasks ();
42
+ $ taskCoroutine = $ task ->runTaskTests ();
46
43
self ::$ isRunningJob = true ;
47
44
$ context = new Context ();
48
45
$ context ->set ('request_time ' , Time::stamp ());
@@ -83,14 +80,16 @@ protected function initTask()
83
80
$ this ->eventChain = $ this ->event ->getEventChain ();
84
81
85
82
$ this ->event ->bind ('test_task_done ' , function () {
86
- echo "task done... \n" ;
87
83
--self ::$ nTasks ;
88
- echo self ::$ nTasks , "\n" ;
89
84
if (self ::$ jobs == []) {
90
85
self ::$ isRunningJob = false ;
91
86
} else {
92
- echo "scheduling...... \n" ;
93
- $ taskCoroutine = array_shift (self ::$ jobs );
87
+ $ task = array_shift (self ::$ jobs );
88
+ $ task ->initTask ();
89
+ $ task ->taskCounter ++;
90
+ $ task ->eventChain ->before ('test_task_num_ ' . $ task ->taskCounter , 'test_task_done ' );
91
+ $ task ->scanTasks ();
92
+ $ taskCoroutine = $ task ->runTaskTests ();
94
93
$ context = new Context ();
95
94
$ context ->set ('request_time ' , Time::stamp ());
96
95
$ request_timeout = 30 ;
@@ -99,7 +98,6 @@ protected function initTask()
99
98
return ;
100
99
}
101
100
if (self ::$ nTasks == 0 ) {
102
- echo "exiting.... \n" ;
103
101
swoole_event_exit ();
104
102
}
105
103
});
0 commit comments