PhpBoot\RPC\MultiRequest

Complexity

Total Complexity

4

Size/Duplication

Total Lines	33
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	1

Test Coverage

Coverage

100%

Importance

Changes

0

3 Methods

Rating	Name	Duplication	Size	Complexity
A	run()	0	11	1
A	isRunning()	0	3	1
A	wait()	0	6	2

<?php

namespace PhpBoot\RPC;

/**
 * 并发执行多个异步请求
 *
 */
class MultiRequest
{
    public static function run(array $threads, callable $waitAll)
    {
        $request = new MultiRequestCore($threads, $waitAll);
        $id = spl_object_hash($request);
        self::$contexts[$id] = $request;
        $oriId = self::$currentContext;
        self::$currentContext = $id;
        $request->run();
        self::$currentContext = $oriId;
        return $request->getResults();
    }

    public static function isRunning(){
        return !!self::$currentContext;
    }

    public static function wait($waitAble)
    {
        self::isRunning() or \PhpBoot\abort("can not call wait() out of MultiRequest::run");
        $request = self::$contexts[self::$currentContext];
        return $request->wait($waitAble);
    }

    /**
     * @var MultiRequestCore[]
     */
    protected static $contexts;
    protected static $currentContext;


}