FilesExpand file tree

 master

/

performance.php

Copy path

Blame

More file actions

Blame

More file actions

Latest commit

 

History

History

History

35 lines (27 loc) · 1.2 KB

 master

/

performance.php

Copy path

Top

File metadata and controls

• Code
• Blame

35 lines (27 loc) · 1.2 KB

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

<?php

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

echo "Process 500 Tasks with an avg 1.5secs (min 1sec, max 2secs)\n";

echo "\t- Without the workerpool this would take about 12.5 minutes (avg)\n";

$timeused=microtime(true);

$wp = new \QXS\WorkerPool\WorkerPool();

$wp->setWorkerPoolSize(100)

->create(new \QXS\WorkerPool\ClosureWorker(

/**

* @param mixed $input the input from the WorkerPool::run() Method

* @param \QXS\WorkerPool\Semaphore $semaphore the semaphore to synchronize calls accross all workers

* @param \ArrayObject $storage a persistent storge for the current child process

*/

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

usleep(rand(1000000,2000000)); // this is the working load!

return NULL;

}

)

);

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

$wp->run($i);

}

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

$timeused=microtime(true)-$timeused;

echo "\t- With the workerpool it took: ".number_format($timeused, 2)." seconds\n";

echo "\t- In this example the workerpool is ". number_format(750/$timeused, 2) ." times faster!\n";

echo "\t- BTW: This is a simulation of a real world example, where we were waiting for remote results. This initiated the development of the workerpool.\n";