非同期プログラミングの方向を指摘させてください。 SitePointは、興味があれば、このトピックに関するいくつかの優(yōu)れた記事（非同期ライブラリの作成やMinecraftの修正など）を公開しています。 ポイントに戻って、トピックにまっすぐに行きましょう！

1回限りのタスクのトレーニング

マルチスレッドの方法で1回限りのタスクを処理したい場(chǎng)合があります（IOバインドタスクの実行など）。この場(chǎng)合、スレッドクラスを使用して新しいスレッドを作成し、その別のスレッドでいくつかの作業(yè)単位を?qū)g行できます。

例：

上記の上記の実行方法は、新しいスレッドで実行する作業(yè)単位です。 Thread :: Startが呼び出されると、新しいスレッドが生成され、実行方法が呼び出されます。次に、生成されたスレッドをメインスレッド（スレッド::結(jié)合経由で）に再加入します。これは、個(gè)々のスレッドが実行を完了するまでブロックします。これにより、結(jié)果を出力しようとする前にタスクが実行を完了したことが保証されます（$ task-＆gt; responseに保存）。

$task = new class extends Thread {
    private $response;

    public function run()
    {
        $content = file_get_contents("http://google.com");
        preg_match("~<title>(.+)</title>~", $content, $matches);
        $this->response = $matches[1];
    }
};

$task->start() && $task->join();

var_dump($task->response); // string(6) "Google"

スレッドクラスを何らかの方法で拡張する必要があります。これは、異なるスレッドで実行するために必要な機(jī)能を提供するだけでなく、暗黙のセキュリティと有用なインターフェイス（リソース同期など）を提供するためです。

class Task extends Threaded
{
    public $response;

    public function someWork()
    {
        $content = file_get_contents('http://google.com');
        preg_match('~<title>(.+)</title>~', $content, $matches);
        $this->response = $matches[1];
    }
}

$task = new Task;

$thread = new class($task) extends Thread {
    private $task;

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

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

$thread->start() && $thread->join();

var_dump($task->response);

スレッドクラスとスレッドクラスの基本をすでに學(xué)んでいるので、殘りの3つ（労働者、揮発性、およびプール）を見てみましょう。

スレッドをリサイクル

各タスクが並列化されるために新しいスレッドを開始するのは費(fèi)用がかかります。これは、PHP內(nèi)にスレッドを?qū)g裝するために、pthreadsが共有されたステートレスアーキテクチャを採用する必要があるためです。これは、PHPインタープリターの現(xiàn)在のインスタンスの実行コンテキスト全體（各クラス、インターフェイス、屬性、および関數(shù)を含む）を、作成したスレッドごとにコピーする必要があることを意味します。これにはパフォーマンスが大きな影響を與える可能性があるため、スレッドは常に可能な限り再利用する必要があります。スレッドを再利用するには、ワーカーの使用またはプールの使用方法は2つあります。

ワーカークラスは、別のスレッドで一連のタスクを同期して実行するために使用されます。これは、新しいワーカーインスタンス（これにより新しいスレッドが作成されます）を作成し、その別のスレッドにタスクを積み重ねることによって行われます（ワーカー::スタックを介して）。

これは簡(jiǎn)単な例です：

$task = new class extends Thread {
    private $response;

    public function run()
    {
        $content = file_get_contents("http://google.com");
        preg_match("~<title>(.+)</title>~", $content, $matches);
        $this->response = $matches[1];
    }
};

$task->start() && $task->join();

var_dump($task->response); // string(6) "Google"

output：

上記のスタック15のタスクは、ワーカー::スタックを介して新しい$ Workerオブジェクトにタスクを設(shè)定し、スタッキング順序で処理します。上記のように、ワーカー::収集方法は、タスクが実行を完了した後にタスクをクリーンアップするために使用されます。 whileループでそれを使用することにより、すべての積み重ねられたタスクが実行され、クリーンアップされるまでメインスレッドをブロックし、その後、ワーカー::シャットダウンをトリガーします。ワーカーを時(shí)期尚早に閉じる（つまり、タスクを?qū)g行する必要がありますが）すべてのタスクが実行されるまでメインスレッドをブロックします - タスクはガベージが収集されません（メモリリークを引き起こします）。

上記の例を調(diào)整して、ワーカープールを使用しましょう。

class Task extends Threaded
{
    public $response;

    public function someWork()
    {
        $content = file_get_contents('http://google.com');
        preg_match('~<title>(.+)</title>~', $content, $matches);
        $this->response = $matches[1];
    }
}

$task = new Task;

$thread = new class($task) extends Thread {
    private $task;

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

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

$thread->start() && $thread->join();

var_dump($task->response);

良い実踐として、タスクを完了した後、常に労働者プログラムやプールのタスクを収集し、手動(dòng)で閉じる必要があります。スレッドクラスを介して作成されたスレッドも、作成者スレッドに再會(huì)する必要があります。

pthreadsおよび（非）変動(dòng)性

導(dǎo)入される最後のクラスは揮発性です。これは、pthreads v3への新しい追加です。 Pthreadsの重要な概念になっているのは、それがなければ、パフォーマンスがひどく劣化するためです。したがって、デフォルトでは、スレッドオブジェクトであるスレッドクラスのプロパティは、現(xiàn)在は不変であるため、最初の割り當(dāng)て後に再割り當(dāng)てすることはできません?，F(xiàn)在、これらの特性を明示的に変異させる傾向がありますが、新しい揮発性クラスを使用して実行できます。

新しい不変性の制約を?qū)g証するために、例をすばやく見てみましょう：

$task = new class extends Thread {
    private $response;

    public function run()
    {
        $content = file_get_contents("http://google.com");
        preg_match("~<title>(.+)</title>~", $content, $matches);
        $this->response = $matches[1];
    }
};

$task->start() && $task->join();

var_dump($task->response); // string(6) "Google"

class Task extends Threaded
{
    public $response;

    public function someWork()
    {
        $content = file_get_contents('http://google.com');
        preg_match('~<title>(.+)</title>~', $content, $matches);
        $this->response = $matches[1];
    }
}

$task = new Task;

$thread = new class($task) extends Thread {
    private $task;

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

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

$thread->start() && $thread->join();

var_dump($task->response);

<code>Threaded (implements Traversable, Collectable)
    Thread
        Worker
    Volatile
Pool</code>

デモとして

class Task extends Threaded
{
    private $value;

    public function __construct(int $i)
    {
        $this->value = $i;
    }

    public function run()
    {
        usleep(250000);
        echo "Task: {$this->value}\n";
    }
}

$worker = new Worker();
$worker->start();

for ($i = 0; $i < 15; $i++) {
    $worker->stack(new Task($i));
}

while ($worker->collect());

$worker->shutdown();

この記事で紹介する最後のトピックは、pthreadsでの同期です。同期は、共有リソースへの制御アクセスを可能にするテクノロジーです。

シンプルなカウンターを?qū)g裝しましょう：

class Task extends Threaded
{
    private $value;

    public function __construct(int $i)
    {
        $this->value = $i;
    }

    public function run()
    {
        usleep(250000);
        echo "Task: {$this->value}\n";
    }
}

$pool = new Pool(4);

for ($i = 0; $i < 15; $i++) {
    $pool->submit(new Task($i));
}

while ($pool->collect());

$pool->shutdown();

正しい出力を取得するように同期を追加してこれを修正しましょう20：

class Task extends Threaded // a Threaded class
{
    public function __construct()
    {
        $this->data = new Threaded();
        // $this->data is not overwritable, since it is a Threaded property of a Threaded class
    }
}

$task = new class(new Task()) extends Thread { // a Threaded class, since Thread extends Threaded
    public function __construct($tm)
    {
        $this->threadedMember = $tm;
        var_dump($this->threadedMember->data); // object(Threaded)#3 (0) {}
        $this->threadedMember = new StdClass(); // invalid, since the property is a Threaded member of a Threaded class
    }
};

以下は、2つの同期中のループからのインターリーブの増分です。

スレッド:: waitの呼び出しの周りに追加の條件が追加されていることに気付いたかもしれません。これらの條件は、通知が

class Task extends Volatile
{
    public function __construct()
    {
        $this->data = new Threaded();
        $this->data = new StdClass(); // valid, since we are in a volatile class
    }
}

$task = new class(new Task()) extends Thread {
    public function __construct($vm)
    {
        $this->volatileMember = $vm;

        var_dump($this->volatileMember->data); // object(stdClass)#4 (0) {}

        // still invalid, since Volatile extends Threaded, so the property is still a Threaded member of a Threaded class
        $this->volatileMember = new StdClass();
    }
};

虛偽のウェイクアップコールに対して脆弱になります。これにより、コードが予測(cè)不可能になります。

結(jié)論

各クラスの使用を?qū)毪工毪胜?、Pthreadsが付屬する5つのクラス（スレッド、スレッド、ワーカー、揮発性、プール）が見られました。また、Pthreadsの不変性の新しい概念と、サポートする同期機(jī)能をすばやく調(diào)べました。これらの基本がカバーされているので、いくつかの実際のユースケースにpthreadsを適用することを検討することができます！これが次の投稿の主題になります。

php

FAQ（FAQ）

PTHREADSでのエラー処理は、標(biāo)準(zhǔn)のPHPでのエラー処理に似ています。トライキャッチブロックを使用して例外をキャッチできます。ただし、各スレッドには獨(dú)自のスコープがあるため、1つのスレッドの例外は他のスレッドに影響しないことに注意してください。

LaravelやSymfonyなどのPHPフレームワークでpthreadsを使用できますか？

pthreadsは、LaravelやSymfonyなどのPHPフレームワークと互換性がありません。これは、これらのフレームワークがスレッドセーフになるように設(shè)計(jì)されていないためです。これらのフレームワークで並列処理を?qū)g行する必要がある場(chǎng)合は、キューや非同期タスクなどの他の手法の使用を検討してください。

pthreadsを使用してphpスクリプトをデバッグする方法は？