File: Task/Listener/MainServer.php
Package: Default
Class hierarchy: \Imi\Task\Listener\MainServer
Implements: \Imi\Server\Event\Listener\ITaskEventListener

Methods

handle()

handle(\Imi\Server\Event\Param\TaskEventParam  $e) : void

事件处理方法

Parameters

\Imi\Server\Event\Param\TaskEventParam

<?php
namespace Imi\Task\Listener;

use Imi\Task\TaskInfo;
use Imi\RequestContext;
use Imi\Bean\Annotation\Listener;
use Imi\Server\Event\Param\TaskEventParam;
use Imi\Server\Event\Listener\ITaskEventListener;

/**
 * @Listener("IMI.MAIN_SERVER.TASK")
 */
class MainServer implements ITaskEventListener
{
    /**
     * 事件处理方法
     * @param TaskEventParam $e
     * @return void
     */
    public function handle(TaskEventParam $e)
    {
        $taskInfo = $e->data;
        if($taskInfo instanceof TaskInfo)
        {
            $result = $taskInfo->getTaskHandler()->handle($taskInfo->getParam(), $e->server->getSwooleServer(), $e->taskID, $e->workerID);
            if($e->workerID >= 0 && $e->workerID < $e->server->getSwooleServer()->setting['worker_num'])
            {
                if($e->task)
                {
                    $e->task->finish($result);
                }
                else
                {
                    $e->server->getSwooleServer()->finish($result);
                }
            }
        }
    }
}