詳解c++ libuv工作隊(duì)列

更新時(shí)間：2021年02月01日 10:19:53 作者：sherlock_lin

這篇文章主要介紹了c++ libuv工作隊(duì)列的相關(guān)資料,幫助大家更好的理解和使用libuv，感興趣的朋友可以了解下

1、說明

libuv 提供了一個(gè)線程池，可用于運(yùn)行用戶代碼，libuv 中的工作隊(duì)列中的任務(wù)會(huì)在線程池中執(zhí)行

libuv 中的線程池在內(nèi)部用于運(yùn)行所有文件系統(tǒng)操作以及 getaddrinfo() 和 getnameinfo() 請(qǐng)求

libuv 中的線程池的默認(rèn)數(shù)量為4，可以在啟動(dòng)時(shí)修改環(huán)境變量 UV_THREADPOOL_SIZE 來修改，最大值為 1024（1.30.0版本之前是128）

libuv 中的線程池是全局的，并在所有事件循環(huán)之間共享，當(dāng)特定的函數(shù)利用 uv_queue_work() 方法使用工作隊(duì)列時(shí)，libuv 會(huì)預(yù)分配線程池，以較小的內(nèi)存開銷（128個(gè)線程為1MB），來提高線程性能

以下三種類型的操作會(huì)在全局線程池中進(jìn)行：

文件系統(tǒng)操作；
DNS函數(shù)（getaddrinfo 和 getnameinfo）；
使用 uv_queue_work() 調(diào)度的用戶代碼；

需要注意的是，即使使用了線程池，libuv 的方法也不是線程安全的

2、API

2.1、uv_queue_work

int uv_queue_work(uv_loop_t* loop, 
         uv_work_t* req, 
         uv_work_cb work_cb, 
         uv_after_work_cb after_work_cb);

添加一個(gè)任務(wù)到工作隊(duì)列中，在主線程中調(diào)用

loop：事件循環(huán)

req：傳入到任務(wù)的數(shù)據(jù)，一般使用 req.data 參數(shù)傳遞

work_cb：執(zhí)行方法

after_work_cb：執(zhí)行方法完成后執(zhí)行

work_cb 方法會(huì)在函數(shù)中執(zhí)行，after_work_cb 方法在創(chuàng)建線程中執(zhí)行

void (*uv_work_cb)(uv_work_t* req);
void (*uv_after_work_cb)(uv_work_t* req, int status);

如果調(diào)用 uv_cancel 方法取消了隊(duì)列，則 uv_after_work_cb 的 status 為 UV_ECANCELED

2.2、uv_cancel

int uv_cancel(uv_req_t* req);

取消未執(zhí)行的隊(duì)列中的任務(wù)，在任務(wù)中調(diào)用

req 為任務(wù)的參數(shù)

如果調(diào)用此方法取消了任務(wù)，則 after_work_cb 回調(diào)函數(shù)的 status 的值為 UV_ECANCELED；

3、代碼示例

#include <iostream>
#include <pthread.h>
#include <unistd.h>
#include <uv.h>

void print(uv_work_t *req)
{
  sleep(1);
  long num = (long)req->data;
  printf("thread id is: %ld, num is: %d\n", uv_thread_self(), num);
}

void after_print(uv_work_t *req, int status)
{
  printf("after print, req data is %d, status is %d\n", req->data, status);
}

int main()
{
  uv_loop_t *loop = uv_default_loop();
  uv_work_t req[5];

  for (int index = 0; index < 5; index++)
  {
    req[index].data = (void *)(long)index;
    uv_queue_work(loop, &req[index], print, after_print);
    sleep(1);
  }

  return uv_run(loop, UV_RUN_DEFAULT);
}

示例中的代碼，每次執(zhí)行 print() 方法都是在不同線程中，after_print() 方法和 main() 方法在同一個(gè)線程中

以上就是詳解c++ libuv工作隊(duì)列的詳細(xì)內(nèi)容，更多關(guān)于c++ libuv工作隊(duì)列的資料請(qǐng)關(guān)注腳本之家其它相關(guān)文章！

您可能感興趣的文章: