AsyncPool Class Reference

Public Member Functions
	__construct (Server $server, $size)
	getSize ()
	increaseSize ($newSize)
	submitTaskToWorker (AsyncTask $task, $worker)
	submitTask (AsyncTask $task)
	removeTasks ()
	collectTasks ()

Protected Attributes
	$size

Constructor & Destructor Documentation

__construct()

__construct	(	Server	$server,
			$size
	)

AsyncPool constructor.

Parameters

Server	$server
	$size

                                                      {
        $this->server = $server;
        $this->size = (int) $size;

        for($i = 0; $i < $this->size; ++$i){
            $this->workerUsage[$i] = 0;
            $this->workers[$i] = new AsyncWorker($this->server->getLogger(), $i + 1);
            $this->workers[$i]->setClassLoader($this->server->getLoader());
            $this->workers[$i]->start();
        }
    }

Member Function Documentation

collectTasks()

collectTasks

(

)

                                  {
        Timings::$schedulerAsyncTimer->startTiming();

        foreach($this->tasks as $task){
            if($task->isFinished() and !$task->isRunning() and !$task->isCrashed()){

                if(!$task->hasCancelledRun()){
                    $task->onCompletion($this->server);
                }

                $this->removeTask($task);
            }elseif($task->isTerminated() or $task->isCrashed()){
                $this->server->getLogger()->critical("Could not execute asynchronous task " . (new \ReflectionClass($task))->getShortName() . ": Task crashed");
                $this->removeTask($task, true);
            }
        }

        Timings::$schedulerAsyncTimer->stopTiming();
    }

getSize()

getSize

(

)

Returns

int

                             {
        return $this->size;
    }

increaseSize()

increaseSize

(

$newSize

)

Parameters

$newSize

                                          {
        $newSize = (int) $newSize;
        if($newSize > $this->size){
            for($i = $this->size; $i < $newSize; ++$i){
                $this->workerUsage[$i] = 0;
                $this->workers[$i] = new AsyncWorker($this->server->getLogger(), $i + 1);
                $this->workers[$i]->setClassLoader($this->server->getLoader());
                $this->workers[$i]->start();
            }
            $this->size = $newSize;
        }
    }

removeTasks()

removeTasks

(

)

                                 {
        do{
            foreach($this->tasks as $task){
                $task->cancelRun();
                $this->removeTask($task);
            }

            if(count($this->tasks) > 0){
                Server::microSleep(25000);
            }
        }while(count($this->tasks) > 0);

        for($i = 0; $i < $this->size; ++$i){
            $this->workerUsage[$i] = 0;
        }

        $this->taskWorkers = [];
        $this->tasks = [];
    }

submitTask()

submitTask

(

AsyncTask

$task

)

Parameters

AsyncTask

$task

                                               {
        if(isset($this->tasks[$task->getTaskId()]) or $task->isGarbage()){
            return;
        }

        $selectedWorker = mt_rand(0, $this->size - 1);
        $selectedTasks = $this->workerUsage[$selectedWorker];
        for($i = 0; $i < $this->size; ++$i){
            if($this->workerUsage[$i] < $selectedTasks){
                $selectedWorker = $i;
                $selectedTasks = $this->workerUsage[$i];
            }
        }

        $this->submitTaskToWorker($task, $selectedWorker);
    }

submitTaskToWorker()

submitTaskToWorker	(	AsyncTask	$task,
			$worker
	)

Parameters

AsyncTask	$task
	$worker

                                                                {
        if(isset($this->tasks[$task->getTaskId()]) or $task->isGarbage()){
            return;
        }

        $worker = (int) $worker;
        if($worker < 0 or $worker >= $this->size){
            throw new \InvalidArgumentException("Invalid worker $worker");
        }

        $this->tasks[$task->getTaskId()] = $task;

        $this->workers[$worker]->stack($task);
        $this->workerUsage[$worker]++;
        $this->taskWorkers[$task->getTaskId()] = $worker;
    }

Field Documentation

$size

$size

protected

---

The documentation for this class was generated from the following file:

• src/pocketmine/scheduler/AsyncPool.php