FilesExpand file tree

 master

/

parallelClosure.php

Copy path

Blame

More file actions

Blame

More file actions

Latest commit

 

History

History

History

44 lines (35 loc) · 968 Bytes

 master

/

parallelClosure.php

Copy path

Top

File metadata and controls

• Code
• Blame

44 lines (35 loc) · 968 Bytes

Raw

Copy raw file

Download raw file

Open symbols panel

Edit and raw actions

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

<?php

/**

* Thisfile requires the jeremeamia/SuperClosure

*/

require_once(__DIR__ . '/../autoload.php');

if(file_exists(__DIR__.'/../../../autoload.php')) {

require_once(__DIR__.'/../../../autoload.php');

}

else {

die("Cannot find a classloader for jeremeamia/SuperClosure!\n");

}

use QXS\WorkerPool\WorkerPool,

QXS\WorkerPool\SuperClosureWorker,

QXS\WorkerPool\SerializableWorkerClosure;

$wp=new WorkerPool();

$wp->setWorkerPoolSize(4)

->create(new SuperClosureWorker());

for($i=0; $i<10; $i++) {

$wp->run(new SerializableWorkerClosure(

function($input, $semaphore, $storage) use ($i) {

if($i % 2) {

echo "CHILD ".getmypid()." CODE using $i - received input $input ...\n";

}

else {

echo "child ".getmypid()." Code using $i - received input $input ...\n";

}

return $input / 2;

},

$i * 2

));

}

$wp->waitForAllWorkers(); // wait for all workers

foreach($wp as $val) {

echo "MASTER RECEIVED ".$val['data']."\n";

}