Utilisation du minuteur de travail (avec exemple de code)-Workerman-php.cn

La colonne suivante du tutoriel Workerman php présentera comment utiliser la minuterie Workerman. J'espère qu'elle sera utile aux amis dans le besoin

Utilisation du minuteur de travail (avec exemple de code)

Workerman est un cadre de communication de serveur socket hautes performances, utilisé pour développer rapidement diverses applications réseau, notamment TCP, UDP, connexion longue et applications de connexion courte. Introduisons l'utilisation de la minuterie Workmanman.

ajouter

int \Workerman\Lib\Timer::add(float $time_interval, callable $callback [,$args = array(), bool $persistent = true])

Copier après la connexion

Exécuter régulièrement une fonction ou une méthode de classe

Paramètres

time_interval : à quelle fréquence d'exécution, en secondes, prend en charge les décimales, oui Précis à 0,001, c'est-à-dire précis à la milliseconde près.

callback : fonction de rappel Remarque : si la fonction de rappel est une méthode de la classe, la méthode doit être un attribut public

args : les paramètres de la fonction de rappel, doivent être un tableau, et les éléments du tableau sont des valeurs de paramètres

persistent : Si elle est persistante. Si vous ne souhaitez l'exécuter qu'une seule fois régulièrement, passez false (une tâche qui n'est exécutée qu'une seule fois sera automatiquement détruite après exécution, et il y a pas besoin d'appeler Timer::del()). La valeur par défaut est true, ce qui signifie qu'elle est toujours exécutée régulièrement.

Valeur de retour

Renvoie un entier représentant le timerid du timer. Ce timer peut être détruit en appelant Timer::del($timerid).

Exemple

1. La fonction de timing est une fonction anonyme (fermeture)

use \Workerman\Worker;
use \Workerman\Lib\Timer;
require_once './Workerman/Autoloader.php';

$task = new Worker();
// 开启多少个进程运行定时任务，注意多进程并发问题
$task->count = 1;
$task->onWorkerStart = function($task)
{
    // 每2.5秒执行一次
    $time_interval = 2.5;
    Timer::add($time_interval, function()
    {
        echo "task run\n";
    });
};

// 运行worker
Worker::runAll();

Copier après la connexion

2. La fonction de timing est une fonction ordinaire

require_once './Workerman/Autoloader.php';
use \Workerman\Worker;
use \Workerman\Lib\Timer;

// 普通的函数
function send_mail($to, $content)
{
    echo "send mail ...\n";
}

$task = new Worker();
$task->onWorkerStart = function($task)
{
    $to = 'workerman@workerman.net';
    $content = 'hello workerman';
    // 10秒后执行发送邮件任务，最后一个参数传递false，表示只运行一次
    Timer::add(10, 'send_mail', array($to, $content), false);
};

// 运行worker
Worker::runAll();

Copier après la connexion

3. La fonction de synchronisation est la méthode de classe

require_once './Workerman/Autoloader.php';
use \Workerman\Worker;
use \Workerman\Lib\Timer;

class Mail
{
    // 注意，回调函数属性必须是public
    public function send($to, $content)
    {
        echo "send mail ...\n";
    }
}

$task = new Worker();
$task->onWorkerStart = function($task)
{
    // 10秒后发送一次邮件
    $mail = new Mail();
    $to = 'workerman@workerman.net';
    $content = 'hello workerman';
    Timer::add(10, array($mail, 'send'), array($to, $content), false);
};

// 运行worker
Worker::runAll();

Copier après la connexion

4. La fonction de synchronisation est une méthode de classe (la minuterie est utilisée à l'intérieur de la classe)

require_once './Workerman/Autoloader.php';
use \Workerman\Worker;
use \Workerman\Lib\Timer;

class Mail
{
    // 注意，回调函数属性必须是public
    public function send($to, $content)
    {
        echo "send mail ...\n";
    }

    public function sendLater($to, $content)
    {
        // 回调的方法属于当前的类，则回调数组第一个元素为$this
        Timer::add(10, array($this, 'send'), array($to, $content), false);
    }
}

$task = new Worker();
$task->onWorkerStart = function($task)
{
    // 10秒后发送一次邮件
    $mail = new Mail();
    $to = 'workerman@workerman.net';
    $content = 'hello workerman';
    $mail->sendLater($to, $content);
};

// 运行worker
Worker::runAll();

Copier après la connexion

5. 🎜>

require_once './Workerman/Autoloader.php';
use \Workerman\Worker;
use \Workerman\Lib\Timer;

class Mail
{
    // 注意这个是静态方法，回调函数属性也必须是public
    public static function send($to, $content)
    {
        echo "send mail ...\n";
    }
}

$task = new Worker();
$task->onWorkerStart = function($task)
{
    // 10秒后发送一次邮件
    $to = 'workerman@workerman.net';
    $content = 'hello workerman';
    // 定时调用类的静态方法
    Timer::add(10, array('Mail', 'send'), array($to, $content), false);
};

// 运行worker
Worker::runAll();

Copier après la connexion

6. Timing La fonction est une méthode statique de la classe (avec espace de noms)

namespace Task;
require_once './Workerman/Autoloader.php';
use \Workerman\Worker;
use \Workerman\Lib\Timer;

class Mail
{
    // 注意这个是静态方法，回调函数属性也必须是public
    public static function send($to, $content)
    {
        echo "send mail ...\n";
    }
}

$task = new Worker();
$task->onWorkerStart = function($task)
{
    // 10秒后发送一次邮件
    $to = 'workerman@workerman.net';
    $content = 'hello workerman';
    // 定时调用带命名空间的类的静态方法
    Timer::add(10, array('\Task\Mail', 'send'), array($to, $content), false);
};

// 运行worker
Worker::runAll();

Copier après la connexion

7. Détruisez le timer actuel dans le timer (utilisez la méthode de fermeture pour passer $timer_id)

use \Workerman\Worker;
use \Workerman\Lib\Timer;
require_once './Workerman/Autoloader.php';

$task = new Worker();
$task->onWorkerStart = function($task)
{
    // 计数
    $count = 1;
    // 要想$timer_id能正确传递到回调函数内部，$timer_id前面必须加地址符 &
    $timer_id = Timer::add(1, function()use(&$timer_id, &$count)
    {
        echo "Timer run $count\n";
        // 运行10次后销毁当前定时器
        if($count++ >= 10)
        {
            echo "Timer::del($timer_id)\n";
            Timer::del($timer_id);
        }
    });
};

// 运行worker
Worker::runAll();

Copier après la connexion

8. Détruisez le timer actuel dans le timer Timer (passez $timer_id comme paramètre)

require_once './Workerman/Autoloader.php';
use \Workerman\Worker;
use \Workerman\Lib\Timer;

class Mail
{
    public function send($to, $content, $timer_id)
    {
        // 临时给当前对象添加一个count属性，记录定时器运行次数
        $this->count = empty($this->count) ? 1 : $this->count;
        // 运行10次后销毁当前定时器
        echo "send mail {$this->count}...\n";
        if($this->count++ >= 10)
        {
            echo "Timer::del($timer_id)\n";
            Timer::del($timer_id);
        }
    }
}

$task = new Worker();
$task->onWorkerStart = function($task)
{
    $mail = new Mail();
    // 要想$timer_id能正确传递到回调函数内部，$timer_id前面必须加地址符 &
    $timer_id = Timer::add(1, array($mail, 'send'), array('to', 'content', &$timer_id));
};

// 运行worker
Worker::runAll();

Copier après la connexion

9. Définissez le timer uniquement dans le processus spécifié

Une instance de travailleur a 4 processus. , et réglez-le uniquement sur le processus avec la minuterie du numéro d'identification 0.

use Workerman\Worker;
use Workerman\Lib\Timer;
require_once './Workerman/Autoloader.php';

$worker = new Worker();
$worker->count = 4;
$worker->onWorkerStart = function($worker)
{
    // 只在id编号为0的进程上设置定时器，其它1、2、3号进程不设置定时器
    if($worker->id === 0)
    {
        Timer::add(1, function(){
            echo "4个worker进程，只在0号进程设置定时器\n";
        });
    }
};
// 运行worker
Worker::runAll();

Copier après la connexion

Pour plus de connaissances sur les ouvriers, veuillez faire attention à la colonne

tutoriel sur les ouvriers

Ce qui précède est le contenu détaillé de. pour plus d'informations, suivez d'autres articles connexes sur le site Web de PHP en chinois!