协程基础组件

Testing Is Documentation

tests/Protocol/CoroutineTest.php

协程基础组件主要用于返回当前协程状态以及标识一个服务是否处于协程中，以便于将数据注册到当前协程下面，用于协程上下文。

Uses

<?php

use Leevel\Di\ICoroutine;
use Leevel\Protocol\Coroutine;
use Throwable;

inContext 普通服务是否处于协程上下文

public function testCoroutineContext(): void
{
    $coroutine = new Coroutine();
    $this->assertInstanceOf(ICoroutine::class, $coroutine);
    $this->assertFalse($coroutine->inContext('notFound'));
    $coroutine->addContext('notFound');
    $this->assertTrue($coroutine->inContext('notFound'));
}

inContext 类是否处于协程上下文

类可以通过添加静态方法 coroutineContext 来自动完成协程上下文标识。

public function testCoroutineContextForClass(): void
{
    $coroutine = new Coroutine();
    $this->assertFalse($coroutine->inContext(Demo1::class));
    $coroutine->addContext(Demo1::class);
    $this->assertTrue($coroutine->inContext(Demo1::class));
    $this->assertTrue($coroutine->inContext(Demo2::class));
}

addContext 添加协程上下文键值

public function testAddContext(): void
{
    $coroutine = new Coroutine();
    $this->assertFalse($coroutine->inContext('hello'));
    $this->assertFalse($coroutine->inContext(Demo1::class));
    $coroutine->addContext(Demo1::class, 'hello');
    $this->assertTrue($coroutine->inContext('hello'));
    $this->assertTrue($coroutine->inContext(Demo1::class));
}

removeContext 删除协程上下文键值

public function testRemoveContext(): void
{
    $coroutine = new Coroutine();
    $this->assertFalse($coroutine->inContext('hello'));
    $this->assertFalse($coroutine->inContext(Demo1::class));
    $coroutine->addContext(Demo1::class, 'hello');
    $this->assertTrue($coroutine->inContext('hello'));
    $this->assertTrue($coroutine->inContext(Demo1::class));
    $coroutine->removeContext(Demo1::class, 'hello');
    $this->assertFalse($coroutine->inContext('hello'));
    $this->assertFalse($coroutine->inContext(Demo1::class));
}

当前协程 ID

public function testCoroutineCid(): void
{
    $coroutine = new Coroutine();
    $this->assertSame(-1, $coroutine->cid());

    try {
        go(function () use ($coroutine) {
            $this->assertSame(1, $coroutine->cid());

            go(function () use ($coroutine) {
                $this->assertSame(2, $coroutine->cid());
            });
        });
    } catch (Throwable $th) {
    }
}