1. 程式人生 > 程式設計 >PHP pthread拓展使用和注意點

PHP pthread拓展使用和注意點

一. 執行緒的建立和使用

1. Thread類

基本的建立和使用:

<?php

//通過繼承Thread類來實現自己的執行緒類MyThread

class MyThread extends Thread{

  //重寫建構函式

  function __construct(){

  }

  //重寫run方法(執行的是子執行緒需要執行的任務)

  function run(){

  }

}

//物件的例項化和執行就和java一樣

$mt = new MyThread();

$mt->start();

當然,作為執行緒類,必須還有另外一些用於查詢執行緒狀態以及管理執行緒的方法

<?php

//獲取建立執行緒的父執行緒id

Thread::getCreatorId 

//獲取當前執行緒id

Thread::getCurrentThreadId

//獲取當前執行緒引用

Thread::getCurrentThread 

//將執行緒加入檢測

Thread::join

//檢視執行緒是否被檢測(是否被join)

Thread::isJoined

//強行殺死執行緒

Thread::kill

2.Worker類

Worker類的父類是Thread類,因此基本用法和Thread一樣。而Worker類相對於Thread類來說,增加了執行緒複用的功能(以降低建立銷燬執行緒所耗費的資源),通常與Stackable類連用,也就是說worker類既可以當做執行緒使用,也可以當做任務的容器來使用,如:

<?php

class Task extends Stackable{

  function __construct($no){

    $this->no = $no;

  }

  function run(){

    echo "task{$this->no}:run".PHP_EOL;

  }

}

class MyWork extends Worker{

  function __construct(){

  }

  function run(){

  }

}

$t1= new Task(1);

$t2= new Task(2);

$t3= new Task(3);

$my = new MyWork();

$my->stack($t1);

$my->stack($t2);

$my->start();

$my->stack($t3);

最終輸出:

task1:run

task2:run

task3:run

當然Worker類還有其他一些方法來用於父執行緒對其進行管理

//獲取還沒執行的任務數量

Worker::getStacked 

//判斷worker是否關閉

Worker::isShutdown

//判斷worker是否在工作

Worker::isWorking

//關閉銷燬worker

Worker::shutdown

//將任務壓棧

Worker::stack

//將任務出棧(該api有問題,慎用)

Worker::unstack

二. PHP執行緒遇到的一些問題與注意點

1.執行緒類的屬性不能直接進行雜湊表(陣列)操作,如:

//這樣是無效的

$this->var1["hello"] = "world"; 

//改為

$this->var1 = ["hello"=>"world"];

為什麼?因為執行緒類屬性的賦值是通過序列化實現的,其本質是儲存了序列化資料,因此不支援PHP常用直接操作雜湊表(陣列)的操作。

2.執行緒類的屬性不能是“閉包函式”

原因:閉包函式不能序列化;因此,如果想線上程裡用“回撥函式”的話,那就放棄執行緒吧;

3.執行緒物件開闢了php的第二空間

(1)執行緒在建立之後,無法訪問到父執行緒的變數,諸如$GLOBALS或global等用法都無法操作父執行緒的全域性變數,這應該是考慮到了執行緒安全的問題;

(2)但是父執行緒卻能夠訪問子執行緒物件的內容;

擴充套件內容

php Pthread 多執行緒

執行緒,有時稱為輕量級程序,是程式執行的最小單元。執行緒是程序中的一個實體,是被系統獨立排程和分派的基本單位,執行緒自己不擁有系統資源,它與同屬一個程序的其它執行緒共享程序所擁有的全部資源。一個執行緒可以建立和撤消另一個執行緒,同一程序中的多個執行緒之間可以併發執行。每一個程式都至少有一個執行緒,那就是程式本身,通常稱為主執行緒。執行緒是程式中一個單一的順序控制流程。 在單個程式中同時執行多個執行緒完成不同的工作,稱為多執行緒。

<?php
 
//實現多執行緒必須繼承Thread類
class test extends Thread {
  public function __construct($arg){
    $this->arg = $arg;
  }
 
  //當呼叫start方法時,該物件的run方法中的程式碼將在獨立執行緒中非同步執行。
  public function run(){
    if($this->arg){
      printf("Hello %s\n",$this->arg);
    }
  }
}
$thread = new test("World");
 
if($thread->start()) {
  //join方法的作用是讓當前主執行緒等待該執行緒執行完畢
  //確認被join的執行緒執行結束,和執行緒執行順序沒關係。
  //也就是當主執行緒需要子執行緒的處理結果,主執行緒需要等待子執行緒執行完畢
  //拿到子執行緒的結果,然後處理後續程式碼。
  $thread->join();
}
?>

我們把上述程式碼修改一下,看看效果

<?php
 
class test extends Thread {
  public function __construct($arg){
    $this->arg = $arg;
  }
  public function run(){
    if($this->arg){
      sleep(3);
      printf("Hello %s\n",$this->arg);
    }
  }
}
$thread = new test("World");
 
$thread->start();
 
echo "main thread\r\n";
?>

我們直接呼叫start方法,而沒有呼叫join。主執行緒不會等待,而是在輸出main thread。子執行緒等待3秒才輸出Hello World。