PHP は Gearman 拡張機能をインストールして、非同期タスクや段階的なタスクを実装します。

1

2

3

4

5

6

7

8

9

10

11

12

13

14

15

$worker=newGearmanWorker();

$worker->addServer();

$worker->addFunction('say',function(GearmanJob$job){

    $workload=$job->workload();//接收client传递的数据

    echo'receive data:'.$workload.PHP_EOL;

    returnstrrev($workload);//仅作反转处理

});

//无际循环运行，gearman内部已有处理，不会出现占用过高死掉的情况

while($worker->work()){

    if($worker->returnCode() !== GEARMAN_SUCCESS){

        echo'error'.PHP_EOL;

    }

}

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

宣言(ティック) = 1 );

$num= 5; //子プロセスの最大数

$child= 0; //現在の子プロセス数

// 信号処理関数

functionig_handler($sig)

{

global$child;

switch($sig) {

caseSIGCHLD :

$child--;

echo'SIGCHLD を受け取りました!' プロセス'.PHP_EOL; 🎜>

caseSIGINT:

$child--;

echo'SIGINT を受け取りました!これで「.$child」ができました。プロセス'.PHP_EOL;

休憩;

caseSIGTERM:

$child--;

echo'SIGTERMを受け取りました！これで「.$child」ができました。プロセス'.PHP_EOL;   

休憩;

デフォルト:

# コード...

break;

}

}

// インストール信号处処理器

pcntl_signal(SIGTERM,"sig_handler");//进程キル時に発行されるシグナル

// pcntl_signal(SIGHUP, "sig_handler");// 終了時に発行されるシグナル

pcntl_signal(SIGINT,"sig_handler");// 中断信号、例: Ctrl+C

pcntl_signal(SIGCHLD,"sig_handler");//进程退出信号

while(true)

{

$child++;

$parentpid=getmypid();

$pid= pcntl_fork();//一分二、父进程和子进程都市执行以下代码

if($pid== -1)

{

exit("フォークできません!");//出错

}elseif($pid> 0){

//父进程处理代码

echo「私は親です。私の PID は「.$pid」です。」私の親 PID は '.$parentpid.PHP_EOL;

if($child>=$num)

{

pcntl_wait($status);// 待機中、待機中结束、子进程成を僵尸进程にする

}

}elseif($pid== 0){

//子进程代

エコーアイ私は子で、親の PID は '.$parentpid です。" 私の PID は ".getmypid()。" 現在 $child プロセスがあります。".PHP_EOL;       

//具体的な代価

pcntl_exec('/usr/bin/php',array('/var/www/test/mywork.php'));

}

pcntl_signal_dispatch();// 信号を分割し、取り付けられた信号処理装置が受信できるようにします。

// php5.3 より低いこの関数数は無能ですが、开头の宣言 (ティック = 1); 表示実行一条低級命令、

//就检查次信号、結果检测に注釈の信号、就调使用その信号処理器

sleep(rand(3,5));//100% 占有を防止

}