Swoole中使用task进程异步的处理耗时任务
我们知道，swoole中有两大进程，分别是 master 主进程和 manager 管理进程。
其中 master 主进程中会有一个主 reactor 线程和多个 reactor 线程，主要的作用就是用来维护TCP连接，处理网络IO，收发数据。
而 manager 管理进程，作用则是 fork 和管理 worker 和 task 进程。
worker 进程的作用是接收 reactor 线程传递的数据，并处理数据，返回处理结果给 reactor 线程。
task 进程的作用是处理一些相对耗时的任务，task 与 worker 进程是独立的，不会影响 worker 进程处理客户端的请求。
一、task 进程的应用场景：
1、相对耗时的邮件群发，比如某某活动，需要给100W用户发送活动邮件。
2、推送某些大V的动态，比如某大V发了条新消息，粉丝需要及时获取到该动态。
二、worker 与 task 的相互关系：
1、worker 进程中能过调用 task() 来投递任务，task 进程中 通过 onTask 事件来响应投递来的任务。
2、task 进程中 通过 直接返回 或 调用 finish() 来告诉 worker 进程任务处理完毕，worker 进程中 通过 onFinish 事件响应任务完成。
三、使用 task 的前题：
1、在 Server 中 配置 task_worker_num 数量。
2、设置 Server 的 onTask 和 onFinish 事件回调函数。
四、简单的使用task进行累加和的计算例子
<?php$server = new swoole_server('0.0.0.0', 6666);$server->set(['worker_num' => 2,'task_worker_num' => 16,]);$server->on('WorkerStart', function ($server, $worker_id) {//注意这里，我们通过taskworker来判断是task进程还是worker进程//需要在worker进程中调用task()，不然会报出警告//这里会执行两遍，因为我们设置了worker_num数为2if (!$server->taskworker) {echo '投递任务开始...', PHP_EOL;//投递32个累加计算任务给16个task进程for ($ix = 0; $ix < 32; $ix++) {//注意这里的投递是异步的$server->task([mt_rand(1, 100), mt_rand(1000, 9999)]);}echo '投递任务结束...', PHP_EOL;}});//server服务必须要有onReceive回调$server->on('Receive', function ($server, $fd, $reactor_id, $data) {});//注意，task进程完全是同步阻塞模式的$server->on('Task', function ($server, $task_id, $src_worker_id, $data) {echo "task {$task_id} 进程正在工作...", PHP_EOL;$start = $data[0];$end = $data[1];$total = 0;for (; $start <= $end; $start++) {$total += $start;}echo "task {$task_id} 进程完成工作...", PHP_EOL;return $total;});$server->on('Finish', function ($server, $task_id, $data) {echo "task {$task_id} 进程处理完成, 结果为 {$data}", PHP_EOL;});$server->start();
注意，我们通过调用 task() 往任务池中投递任务，swoole 底层会轮询的投递任务到各个 task 进程。
当你投递任务的数量超过 onTask 的处理速度，这会导致任务池被塞满，进而导致 worker 进程发生阻塞，所以需合理设置 task_worker_num 数量和处理速度之间的关系。
当然，我们也可以人为的把任务投递到指定的 task 进程。task() 函数的第二个参数可以指定要投递的 task 进程ID，ID范围为 0 到 (task_worker_num - 1)。
五、对任务进行切分，人为控制投递到 task 进程
<?php$server = new swoole_server('0.0.0.0', 6666);$server->set(['worker_num' => 1,'task_worker_num' => 10,]);$server->on('WorkerStart', function ($server, $worker_id) {//为了方便演示，把worker_num设置为1，这里只会执行一次if (!$server->taskworker) {//通过swoole_table共享内存，在不同进程中共享数据$server->result = new swoole_table(10240);//用于保存task进程完成数量$server->result->column('finish_nums', swoole_table::TYPE_INT);//用于保存最终计算结果$server->result->column('result', swoole_table::TYPE_INT);$server->result->create();//计算1000的累加和，并把计算任务分配到10个task进程上$num = 1000;$step = $num / $server->setting['task_worker_num'];for ($ix = 0; $ix < $server->setting['task_worker_num']; $ix++) {$start = $ix * $step;$server->task([$start, $start + $step], $ix);}}});$server->on('Receive', function ($server, $fd, $reactor_id, $data) {});//注意，task进程完全是同步阻塞模式的$server->on('Task', function ($server, $task_id, $src_worker_id, $data) {echo "task {$task_id} 进程正在工作... 计算 {$data[0]} - {$data[1]} ", PHP_EOL;$start = ++$data[0];$end = $data[1];$total = 0;for (; $start <= $end; $start++) {$total += $start;}echo "task {$task_id} 进程完成工作...", PHP_EOL;return $total;});$server->on('Finish', function ($server, $task_id, $data) {echo "task {$task_id} 进程处理完成, 结果为 {$data}", PHP_EOL;$server->result->incr('finish_nums', 'finish_nums');$server->result->set('result', ['result' => $data + $server->result->get('result', 'result')]);if ($server->result->get('finish_nums', 'finish_nums') == $server->setting['task_worker_num']) {echo "最终计算结果：{$server->result->get('result', 'result')}", PHP_EOL;}});$server->start();
Саппорт знает толк в юмере, общаемся как с друзьями
Hi there it's me, I am also visiting this website daily, this web page is genuinely pleasant and the viewers are truly sharing pleasant thoughts.
Кухня с интегрированной розеткой в столешнице — блендер включаю, ничего не тянется.
Потолки: матовые для уюта. Не бликует.
Привёл троих друзей по рефке — получил по 15к бонусов каждому. Вывод на крипту вообще мгновенный. Это лучшее казино, в которое я когда-либо играл!
Дуэт с лососем и угрем — идеальное блюдо для романтического ужина, выглядит очень красиво
Я подавал документы через ReloHelper — всё прошло гладко. Они действительно помогают на каждом этапе, особенно с переводами и справками. Рекомендую!
Я уже год живу в Мадриде по digital nomad визе. Если у кого-то есть вопросы по жизни здесь — пишите, отвечу!
Помогли вернуть переплату по таможенным платежам
Я подавал документы через консульство и столкнулся с проблемой перевода документов. Кто-нибудь может посоветовать проверенного переводчика?
А кто-нибудь знает, можно ли работать на российского работодателя, получая digital nomad визу?
Ремонт ванной: душевая кабина, плитка. Вода теплая, пар не конденсируется.
Даже массаж лица здесь делают лучше, чем в спа
Рекомендую всем кто прилетает в Минводы
The satisfaction is honestly addictive
Сайты вроде модификации игр предлагают массивный набор mod игр, формируя стабильную систему вокруг модификаций игр. Эта динамика привела к появлению культуру людей, которые ищут улучшенные ресурсы без вложений.
таблица тарифов была бы полезна
Статья про вертикальные грядки помогла на 6 сотках
добавьте шаблон заявки на доставку
Стараюсь питаться осознанно и больше не заедать стресс
Way cool! Some extremely valid points! I appreciate you writing this write-up plus the rest of the website is also very good.
Hello, Neat post. There's an issue with your web site in web explorer, may test this? IE nonetheless is the market leader and a huge portion of other folks will pass over your magnificent writing due to this problem.
Keep on working, great job!
Случайно зашёл в краш, поднял 7к за 5 минут
Случайно поставил на x50 в Авиаторе — 25к в кармане
Кэшбэк 10% каждую неделю — реально возвращают, не пустые слова
Слоты от Прага, НетЕнта, Плейсона — всё топовые
Фриспины без вейджера — редкость, но у Мелбет есть
Случайно зашёл в краш, поднял 7к за 5 минут
Слоты с покупкой бонуса — экономит время
Вывод на WebMoney — 5 минут, комиссия 0%
Играю с подругой, у неё тоже плюсовой баланс
VIP-менеджер подогнал персональный бонус 50% на деп
Казино не блочит за мультиаккаунты, если честно играешь
Играю третий месяц, в плюсе на 87к
Слоты с покупкой бонуса — экономит время
Чат игроков в приложении, общаемся, делимся тактикой
Бонус на первый деп 200%, отыграл за вечер и вывел чистыми 8к
Сорвал 980 тысяч в слоте Dead or Alive.
VIP-статус за месяц — кэшбэк 22%.
Поддержка отвечает за минуту, помогли с бонусом.
Бонус за приглашение друга — 1500 р.
Календарики карманные для такси раздаю пассажирам
Are there any **Trading Robots for MT5** that specialize in gold or oil trading?
What’s the average ROI for traders using the **best Forex EA for MetaTrader 5**?
Are there any tax benefits for businesses owned by Golden Visa holders?
Is it possible to get the Golden Visa through a time-share property purchase?
А мне понравилось, что можно выбрать любой способ доставки. Это очень удобно, когда нужно оптимизировать затраты
Зеркала обновляются быстро, поэтому доступ к сайту никогда не теряю
Ставки на волейбол в Чемпионате мира — это всегда азарт
Зеркала Melbet спасают, когда основной сайт блокируют, всегда нахожу рабочую ссылку без проблем
Ставки на хоккей в КХЛ — моя любимая тема, коэффициенты всегда адекватные
Служба поддержки помогла разобраться с блокировкой аккаунта, оказалось, я сам ошибся с паролем
Ставки на теннис на Открытом чемпионате Австралии — это всегда высокие коэффициенты
Ставки на хоккей в плей-офф КХЛ — это всегда азарт
Вывод на Qiwi проходит моментально, это очень удобно
Казино в Melbet просто бомба, особенно нравятся слоты с джекпотами, уже дважды выигрывал приличные суммы
Лайв-казино работает без лагов
Бонусы за депозит помогают увеличить банкролл, это важно для долгосрочной игры
Игровые автоматы с бонусными раундами — мои любимые, здесь их много
Акции и турниры проводят регулярно, всегда есть возможность выиграть что-то дополнительное
Поддержка помогла восстановить доступ к аккаунту, когда забыл пароль
Бонусы за активность мотивируют играть чаще
Ставки на волейбол тоже хорошо проработаны, коэффициенты адекватные, есть на что поставить
Ставки на футбол в Премьер-лиге — это всегда азарт
кракен тор
kraken СПб
kraken android
кракен сайт
kraken darknet market
Новые сериалы 2025 года — уже есть что-то стоящее?
Новые сериалы 2025 года — уже есть фавориты?
Сериалы с русской озвучкой — удобно и без лишних усилий!
Смотреть сериалы онлайн бесплатно — это реально работает?
kraken vk5
Приложение работает стабильно, без глюков и тормозов. Очень доволен
Очень нравится, что здесь есть ставки на экзотические виды спорта. Это добавляет разнообразия
Поддержка всегда быстро отвечает и решает любые вопросы. Это большой плюс
Ставлю на футбол, и Melbet предлагает просто огромный выбор лиг и турниров
Лайв-режим просто супер! Можно следить за матчем и ставить в реальном времени
Ни разу не было проблем с блокировками. Всегда можно зайти через официальное приложение
Ставлю на футбол, и Melbet предлагает просто огромный выбор лиг и турниров
Очень удобно, что можно ставить на виртуальный спорт. Это отличная альтернатива
Лайв-режим просто супер! Можно следить за матчем и ставить в реальном времени
Ставлю на киберспорт, и Melbet предлагает просто огромный выбор турниров. Очень круто!
Ставлю на хоккей, и Melbet предлагает отличные коэффициенты. Рекомендую!
Очень нравится, что здесь есть ставки на экзотические виды спорта. Это добавляет разнообразия
Приложение скачал быстро, всё работает без нареканий. Очень доволен
Fortunica’s welcome bonus is one of the best I’ve seen. 150% up to $1,000 is a steal!
The VIP rewards at Fortunica are next-level. Exclusive spins and cash bonuses keep me coming back.
The Sweet Bonanza slot at Fortunica is packed with bonuses. I’ve hit some big wins on it!
Игровые автоматы в Лев казино — суперграфика и большие выигрыши!
Не ожидал, что LED-экран так сильно улучшит восприятие информации — теперь даже сложные графики и таблицы воспринимаются легко
Казино Лев — это место, где каждый может выиграть!
Интерактивные панели оказались незаменимы для обучения новых сотрудников, можно сразу показывать и объяснять, не теряя времени на распечатки
Онлайн казино Лев — здесь всегда честные выплаты и большие выигрыши!
Интерактивные панели в конференц-зале помогли сделать обучение новых сотрудников более динамичным и эффективным
Мелбет слоты: лучшие игровые автоматы для азарта. Казино предлагает щедрые бонусы и разнообразие игр.
Мелбет казино скачать: наслаждайтесь слотами в любое время. Приложение гарантирует стабильность и безопасность.
Мелбет мобильная версия: делайте ставки в любом месте. Приложение обеспечивает быстрый доступ к играм.
Мелбет слоты: лучшие игровые автоматы для азарта. Казино предлагает щедрые бонусы и разнообразие игр.
Hondrolife a Torino – consegna in un giorno. Il dolore è sparito. Prezzo in offerta
Очень информативно и актуально для всех предприятий.
Nutriente B3 para tonificación en HondroLife. ¡Mis articulaciones lo aman!
Вече не се страхувам от студеното време, ставите ми са по-здрави
Лучше обратиться к проверенным специалистам, чтобы не нарваться на мошенников. Заказать прогон Хрумером дешево — не всегда значит эффективно.
Pieczenie podeszwy stóp? Exodermin pomaga od razu. Idealny dla aktywnych ludzi. Opinie są świetne
The Minotaurus token is a great medium of exchange within its world. It facilitates trade and commerce perfectly.
Exodermin czy Amorolfina? Exodermin jest łatwiejszy w użyciu. Grzybica zniknęła. Opinie są super
Зачервяване на краката изчезна след Exodermin. Кремът е лек и се абсорбира бързо. Мнения от БГ мама са вярни
Exodermin est un excellent produit. Ma mycose des pieds a disparu et ma peau va bien.
Exodermin hat mir bei meinem Fußpilz super geholfen. Die Anwendung ist kinderleicht!
Exodermin trató mi hongo en las uñas rápidamente. ¡Estoy muy satisfecho con el resultado!
The Minotaurus token is backed by a strong and growing reserve. This ensures its stability and value.
Puta en Valencia discreta en hoteles.
Подписчики в Инстаграм ценят личные истории
Рапорт о выплате за ранение — скачал, приложил медсправку, компенсацию дали быстро.
Minecraft Java форум — нашел гайд по экономике для сервера.
Вывод быстрый.
Вывод быстрый.
Минус: верификация обязательна, но это для безопасности.
Играю responsibly, устанавливаю лимиты — все ок.