跳到主要内容

\Co\repeat

API​

namespace Co;

function repeat(Closure $closure,int|float $second): string;

参数说明​

参数类型说明
$closureClosure重复执行的闭包函数,在运行在事件上下文

闭包参数​

参数类型说明
$cancelClosure取消当前重复任务的回调函数

概述​

Repeat (重复执行) , 指定频率重复做某事, 通常用于定时任务等场景。 ripple会为你提交的闭包函数提供一个cancel回调函数, 通过调用cancel函数可以取消当前的重复任务。

基础用法​

\Co\repeat(function (Closure $cancel) {
    echo 'delay task';
    
    
    if(rand(1, 10) === 10){
        $cancel();
    }
}, 1);

\Co\wait(); // 等待所有事件执行完成

注意: repeat方法会在指定的时间间隔内重复执行闭包函数, 直到cancel函数被调用。

\Co\repeat(function (Closure $cancel) {
    \Co\sleep(10);
    
    echo 'delay task';
    
    $cancel();
}, 1);

\Co\wait();

上述例子中, repeat中的代码会在1秒后执行, 并且在遇到\Co\sleep时, 会自动挂起当前协程, 但repeat仍然会在1秒后再次执行。