這篇文章將為大家詳細(xì)講解有關(guān)怎么在PHP中使用pthreads v3同步處理synchronized，文章內(nèi)容質(zhì)量較高，因此小編分享給大家做個(gè)參考，希望大家閱讀完這篇文章后對(duì)相關(guān)知識(shí)有一定的了解。

創(chuàng)新互聯(lián)建站專(zhuān)注于網(wǎng)站建設(shè)，為客戶(hù)提供成都做網(wǎng)站、網(wǎng)站建設(shè)、網(wǎng)頁(yè)設(shè)計(jì)開(kāi)發(fā)服務(wù)，多年建網(wǎng)站服務(wù)經(jīng)驗(yàn)，各類(lèi)網(wǎng)站都可以開(kāi)發(fā)，成都品牌網(wǎng)站建設(shè)，公司官網(wǎng)，公司展示網(wǎng)站，網(wǎng)站設(shè)計(jì)，建網(wǎng)站費(fèi)用，建網(wǎng)站多少錢(qián)，價(jià)格優(yōu)惠，收費(fèi)合理。

比如2個(gè)線(xiàn)程對(duì)變量進(jìn)行加1操作，第1個(gè)線(xiàn)程還沒(méi)來(lái)的及改寫(xiě)數(shù)據(jù)時(shí)，第2個(gè)線(xiàn)程就對(duì)變量進(jìn)行操作了，那變量最終的結(jié)果就是未知的，這個(gè)時(shí)候就需要同步來(lái)進(jìn)行控制了。

例子如下：

<?php
class Count extends Thread
{
  public $cnt = 0;

  public function run()
  {
    $this->add();
  }

  public function add()
  {
    //對(duì)成員進(jìn)行加1操作
    for ($i = 0; $i < 100000; $i++) {
      ++$this->cnt;
    }
  }
}

$c = new Count();
//調(diào)用start()時(shí)，線(xiàn)程run()中就調(diào)用了add()方法
$c->start();
//我們?nèi)藶樵僬{(diào)用一次add()方法，這時(shí)候就會(huì)有兩個(gè)for循環(huán)對(duì)$cnt進(jìn)行操作
$c->add();
//把創(chuàng)建的線(xiàn)程加入主線(xiàn)程中，讓主線(xiàn)程等待子線(xiàn)程運(yùn)行結(jié)束
$c->join();

//這里輸出就是不確定性的
var_dump($c->cnt);

多次運(yùn)行后，$cnt的值是不確定的。如下圖所示：

在pthreads v2中我們可以用Mutex，不過(guò)在v3版本中被刪除了，所以我們可以簡(jiǎn)單的把加1操作放到synchronized中進(jìn)行同步，代碼如下：

<?php
class Count extends Thread
{
  public $cnt = 0;

  public function run()
  {
    $this->add();
  }

  public function add()
  {
    $this->synchronized(function () {
      //對(duì)成員進(jìn)行加1操作
      for ($i = 0; $i < 100000; $i++) {
        ++$this->cnt;
      }
    });
  }
}

$c = new Count();
//調(diào)用start()時(shí)，線(xiàn)程run()中就調(diào)用了add()方法
$c->start();
//我們?nèi)藶樵僬{(diào)用一次add()方法，這時(shí)候就會(huì)有兩個(gè)for循環(huán)對(duì)$cnt進(jìn)行操作
$c->add();
//把創(chuàng)建的線(xiàn)程加入主線(xiàn)程中，讓主線(xiàn)程等待子線(xiàn)程運(yùn)行結(jié)束
$c->join();

//這里就會(huì)一直輸出200000
var_dump($c->cnt);

結(jié)果如下所示：

當(dāng)然我們也可以通過(guò)notify()和wait()進(jìn)行同步控制，代碼如下：

<?php
class Task extends Thread
{
  public $flag = 1;

  public function run()
  {
    $this->synchronized(function () {
      //標(biāo)識(shí)不為1就一直等待
      if ($this->flag !== 1) {
        $this->wait();
      }

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

        echo "flag : {$this->flag} i : {$i} \n";

        if ($this->flag === 1) {
          //設(shè)置標(biāo)識(shí)
          $this->flag = 2;
          //發(fā)送喚醒通知，然后讓當(dāng)前線(xiàn)程等待
          //注意，notify()與wait()順序不要搞錯(cuò)了，不然會(huì)一直阻塞
          $this->notify();
          $this->wait();
        }
      }

      //我們?cè)谶@里再次調(diào)用notify()
      //因?yàn)樵谧詈笠淮屋敵鰂lag : 2 i : 20時(shí)，當(dāng)前線(xiàn)程的i已經(jīng)變成11了，跳出了for循環(huán)，
      //但另一個(gè)線(xiàn)程則一直阻塞在wait()那里，程序無(wú)法結(jié)束，所以需要notify()再次喚醒一次
      $this->notify();
    });
  }
}

$t = new Task();
$t->start();

$t->synchronized(function ($obj) {
  //標(biāo)識(shí)不為2就一直等待
  if ($obj->flag !== 2) {
    $obj->wait();
  }

  for ($i = 11; $i <= 20; $i++) {

    echo "flag : {$obj->flag} i : {$i} \n";

    if ($obj->flag === 2) {
      $obj->flag = 1;
      $obj->notify();
      $obj->wait();
    }
  }
}, $t);

//把創(chuàng)建的線(xiàn)程加入主線(xiàn)程中，讓主線(xiàn)程等待子線(xiàn)程運(yùn)行結(jié)束
$t->join();

結(jié)果如下圖所示：

我們通過(guò)notify()和wait()控制了兩個(gè)for循環(huán)，來(lái)回的輸出變量i的值，保證了順序性。

我們?cè)賮?lái)看一個(gè)復(fù)雜點(diǎn)的例子，共享的資源，如果不進(jìn)行同步操作，會(huì)出現(xiàn)不可預(yù)知的情況，代碼如下：

<?php
class Task extends Thread
{
  private $name;
  private $file;

  public function __construct($name, $file)
  {
    $this->name = $name;
    $this->file = $file;
  }

  public function run()
  {
    $data = file_get_contents($this->file);
    $data = floatval($data);
    for ($i = 0; $i < 100000; $i++) {
      ++$data;
    }
    file_put_contents($this->file, $data);
    echo "task : {$this->name} data : {$data} \n";
  }
}

$tasks = [];
$file = './test.log';

for ($i = 0; $i < 100; $i++) {
  $tasks[$i] = new Task($i, $file);
  $tasks[$i]->start();
}

for ($i = 0; $i < 100; $i++) {
  $tasks[$i]->join();
}

我們開(kāi)100個(gè)線(xiàn)程對(duì)文件test.log進(jìn)行讀寫(xiě)，理想狀態(tài)下，test.log中的數(shù)據(jù)應(yīng)該是每次增加10000000的?，F(xiàn)在的電腦配置都比較好，大家可以多運(yùn)行幾次就可以看出效果。

 很明顯最后的數(shù)據(jù)好像少了200000，多線(xiàn)程下對(duì)test.log文件進(jìn)行讀寫(xiě)，而我們又沒(méi)有加鎖，顯然是會(huì)出現(xiàn)數(shù)據(jù)混亂的。

現(xiàn)在我們修改一下代碼，如下：

<?php
class File extends Thread
{
  private $file;

  public function __construct($file)
  {
    $this->file = $file;
  }

  public function inc()
  {
    //進(jìn)行同步控制，當(dāng)100個(gè)task線(xiàn)程調(diào)用inc方法時(shí)，synchronized可以保證塊內(nèi)的代碼是同步的
    //注意，注意，不要把inc方法寫(xiě)到Task里，那樣是沒(méi)效果的，因?yàn)槊總€(gè)task線(xiàn)程都是獨(dú)立空間，他們各自調(diào)各自的inc方法，是沒(méi)法做到同步的
    //常用的做法是我們要同步哪些資源，就為這些資源寫(xiě)個(gè)Thread類(lèi)，并提供操作這些資源的方法，并在方法里加上synchronized
    return $this->synchronized(function () {
      $data = file_get_contents($this->file);
      $data = floatval($data);
      for ($i = 0; $i < 100000; $i++) {
        ++$data;
      }
      file_put_contents($this->file, $data);
      return $data;
    });
  }
}

class Task extends Thread
{
  private $name;
  private $file;

  public function __construct($name, $file)
  {
    $this->name = $name;
    $this->file = $file;
  }

  public function run()
  {
    $data = $this->file->inc();
    echo "task : {$this->name} data : {$data} \n";
  }
}

$tasks = [];
$file = new File('./test.log');

for ($i = 0; $i < 100; $i++) {
  $tasks[$i] = new Task($i, $file);
  $tasks[$i]->start();
}

for ($i = 0; $i < 100; $i++) {
  $tasks[$i]->join();
}

結(jié)果如下圖所示，當(dāng)然為了保險(xiǎn)起見(jiàn)，我們可以試著多運(yùn)行幾次，下面是我運(yùn)行了25次的結(jié)果：

PHP開(kāi)發(fā)環(huán)境搭建工具有哪些

一、phpStudy，是一個(gè)新手入門(mén)最常用的開(kāi)發(fā)環(huán)境。二、WampServer，WampServer也同樣的也是和phpStudy一樣操作簡(jiǎn)單對(duì)小白比較友好。三、XAMPP，XAMPP（Apache+MySQL+PHP+PERL）是一個(gè)功能強(qiáng)大的建站集成軟件包；四、MAMP，MAMP分為兩種MAMP和MAMP Pro for Mac。五、寶塔面板，寶塔面板是一款服務(wù)器管理軟件，支持windows和linux系統(tǒng)。六、UPUPW，UPUPW是目前Windows平臺(tái)下最具特色的Web服務(wù)器PHP套件。

關(guān)于怎么在PHP中使用pthreads v3同步處理synchronized就分享到這里了，希望以上內(nèi)容可以對(duì)大家有一定的幫助，可以學(xué)到更多知識(shí)。如果覺(jué)得文章不錯(cuò)，可以把它分享出去讓更多的人看到。

分享標(biāo)題：怎么在PHP中使用pthreadsv3同步處理synchronized-創(chuàng)新互聯(lián)
本文來(lái)源：http://aaarwkj.com/article14/iojge.html

成都網(wǎng)站建設(shè)公司_創(chuàng)新互聯(lián)，為您提供網(wǎng)站設(shè)計(jì)、品牌網(wǎng)站建設(shè)、網(wǎng)站改版、網(wǎng)站排名、動(dòng)態(tài)網(wǎng)站、全網(wǎng)營(yíng)銷(xiāo)推廣

廣告

聲明：本網(wǎng)站發(fā)布的內(nèi)容（圖片、視頻和文字）以用戶(hù)投稿、用戶(hù)轉(zhuǎn)載內(nèi)容為主，如果涉及侵權(quán)請(qǐng)盡快告知，我們將會(huì)在第一時(shí)間刪除。文章觀(guān)點(diǎn)不代表本網(wǎng)站立場(chǎng)，如需處理請(qǐng)聯(lián)系客服。電話(huà)：028-86922220；郵箱：631063699@qq.com。內(nèi)容未經(jīng)允許不得轉(zhuǎn)載，或轉(zhuǎn)載時(shí)需注明來(lái)源： 創(chuàng)新互聯(lián)