<?php

//error_reporting();

use Swoole\Process;

include_once __DIR__."/../vendor/autoload.php";

\Co\run(function (){
    $goNum = 0;
    while (true){

        if($goNum>=200){
            break;
        }

        // 需要同步的id
        $id = redis()->lPop('sync_email_lists');

        if($id && is_numeric($id)){
            // 占用当前的id,占用2小时
            if(redis()->add('just_sync_'.$id,time(),600)){
                // 启动一个协程
                go(function () use ($id,&$goNum){
                    $goNum++;
                    try{
                        // 开始同步
                        (new \Service\SyncMail($id))->sync();
                    }catch (Throwable $e){
                        logs('sync : '.$e->getMessage());
                    }


                    // 协程完成后执行的函数
                    co::defer(function () use ($id,&$goNum){
                        $goNum--;
                        // 30秒后 消除占用
                        redis()->expire('just_sync_'.$id,60);
                        // 写入日志
                        \Lib\Log::getInstance()->write();
                    });

                });

            }
        }else{
            break;
        }
    }

    while ($goNum == 0){
        co::sleep(0.5);
        break;
    }
});