php - 在 PHP 中同步和暂停线程

Question

我同时运行 2 个线程，但我有一个关键部分，我需要在 MySql 数据库中放置一些东西。问题是他们可以同时放入相同的东西。

我做了一些计算，表明要索引 20000 个不同的新闻页面，索引从 20000 到 20020。(所以 0 到 20 是重复的)

如何在另一个线程访问数据库时暂停一个线程？

-----thread.php
class Process extends Thread {

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

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

-------------- work

function work($website_url) {
    while(condition) {
        some work...

        if(something->check){      // if this exist in base
            mysqli->query("INSERT something IN db..."); 
            prepare bind exec...
        }
        // between check and insert, second thread can put that element
        // critical section is really small but sometimes occurs ...
    }
}

------ main.php

$job1 = new Process($website_url,$trigger);
$job2 = new Process($website_url,$trigger);

$job1->start();
$job2->start();

Answer 1

互斥

在这里实现您想要的最简单方法是使用单个互斥体:

<?php
class Process extends Thread {

    public function __construct($url, $mutex) {
        $this->url = $url;
        $this->mutex = $mutex;
    }

    public function run() {
        work($this->url, $this->mutex);
    }

    protected $url;
    protected $mutex;
}

function work($url, $mutex) {
    while (1) {
        /* some work */

        /* failing to check the return value of calls to acquire
            or release mutex is bad form, I haven't done so for brevity */
        Mutex::lock($mutex);
        {
            /* critical section */
            printf("working on %s\n", $url);

            /* sleeping here shows you that the critical section is 
                not entered by the second thread, this is obviously not needed */
            sleep(1);
        }
        Mutex::unlock($mutex);

        /* breaking here allows the example code to end, not needed */
        break;
    }
}

$website = "stackoverflow.com";

$lock = Mutex::create();

$jobs = [
    new Process($website, $lock),
    new Process($website, $lock)
];

foreach ($jobs as $job)
    $job->start();

foreach ($jobs as $job)
    $job->join();

/* always destroy mutex when finished with them */    
Mutex::destroy($lock);
?>

这段代码应该可以自行解释，我添加了一些注释来指导您完成它。