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。