FilesExpand file tree

 master

/

completeExample.php

Copy path

Blame

More file actions

Blame

More file actions

Latest commit

 

History

History

History

90 lines (77 loc) · 3.05 KB

 master

/

completeExample.php

Copy path

Top

File metadata and controls

• Code
• Blame

90 lines (77 loc) · 3.05 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

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

<?php

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

use QXS\WorkerPool\WorkerPool;

use QXS\WorkerPool\WorkerInterface;

use QXS\WorkerPool\Semaphore;

/**

* Our Worker Class

*/

Class MyWorker implements WorkerInterface {

protected $sem;

/**

* after the worker has been forked into another process

*

* @param \QXS\WorkerPool\Semaphore $semaphore the semaphore to run synchronized tasks

* @throws \Exception in case of a processing Error an Exception will be thrown

*/

public function onProcessCreate(Semaphore $semaphore) {

// semaphore can be used in the run method to synchronize the workers

$this->sem=$semaphore;

// write something to the stdout

echo "\t[".getmypid()."] has been created.\n";

// initialize mt_rand

list($usec, $sec) = explode(' ', microtime());

mt_srand( (float) $sec + ((float) $usec * 100000) );

}

/**

* before the worker process is getting destroyed

*

* @throws \Exception in case of a processing Error an Exception will be thrown

*/

public function onProcessDestroy() {

// write something to the stdout

echo "\t[".getmypid()."] will be destroyed.\n";

}

/**

* run the work

*

* @param Serializeable $input the data, that the worker should process

* @return Serializeable Returns the result

* @throws \Exception in case of a processing Error an Exception will be thrown

*/

public function run($input) {

$input=(string)$input;

echo "\t[".getmypid()."] Hi $input\n";

sleep(mt_rand(0,10)); // this is the workload!

// and sometimes exceptions might occur

if(mt_rand(0,10)==9) {

throw new \RuntimeException('We have a problem for '.$input.'.');

}

return "Hi $input"; // return null here, in case you do not want to pass any data to the parent

}

}

$wp=new WorkerPool();

$wp->setWorkerPoolSize(10)

->create(new MyWorker());

// produce some tasks

for($i=1; $i<=50; $i++) {

$wp->run($i);

}

// some statistics

echo "Busy Workers:".$wp->getBusyWorkers()." Free Workers:".$wp->getFreeWorkers()."\n";

// wait for completion of all tasks

$wp->waitForAllWorkers();

// collect all the results

foreach($wp as $val) {

if(isset($val['data'])) {

echo "RESULT: ".$val['data']."\n";

}

elseif(isset($val['workerException'])) {

echo "WORKER EXCEPTION: ".$val['workerException']['class'].": ".$val['workerException']['message']."\n".$val['workerException']['trace']."\n";

}

elseif(isset($val['poolException'])) {

echo "POOL EXCEPTION: ".$val['poolException']['class'].": ".$val['poolException']['message']."\n".$val['poolException']['trace']."\n";

}

}

// write something, before the parent exits

echo "ByeBye\n";