在 Windows 代碼庫中，有一個常量INFINITE，它由第二個參數傳遞。此常量指示線程無限期地等待事件。常量在WinBase.h中聲明，定義為0xFFFFFFFF（或 -1）。

此外，Windows代碼還包括WAIT_TIMEOUT。此條件在 Linux 中沒有表示。實際上，借助以下功能可以繞過此限制：

int pthread_tryjoin_np(pthread_t thread, void **retval);

int pthread_timedjoin_np(

pthread_t thread,

void **retval,

const struct timespec *abstime

);

如果您參考pthread_tryjoin_np幫助頁面，您可以看到EBUSY可能是一個錯誤，并且 WaitForSingleObject無法通知我們。要了解線程的狀態并識別其退出代碼，必須調用該函數：

BOOL GetExitCodeThread（HANDLE hThread， PDWORD pdwExitCode）;

退出代碼作為pdwExitCode指向的變量返回。如果在調用函數時線程尚未終止，則STILL_ACTIVE標識符將填充為變量。如果調用成功，則函數返回TRUE。

讓我們考慮一個 Linux 的pthread_tryjoin_np函數用法和Windows 的 GetExitCodeThreadWaitForSingleObject函數的情況。

#ifdef __PL_WINDOWS__

DWORD dwret;

BOOL bret;

DWORD h_process_command_thread_exit_code;

if (h_process_command_thread != NULL) {

bret = GetExitCodeThread(

h_process_command_thread,

&h_process_command_thread_exit_code

);

if (h_process_command_thread_exit_code == STILL_ACTIVE) {

dwret = WaitForSingleObject(

h_process_command_thread,

5000 // 5000ms

);

switch (dwret) {

case WAIT_OBJECT_0:

// everything from this point on is good break;

case WAIT_TIMEOUT:

case WAIT_FAILED:

default:

SetLastError(dwret);

break;

}

}

}

#endif //__PL_WINDOWS__

#ifdef __PL_LINUX__

int iret;

struct timespec wait_time = { 0 };

if (h_process_command_thread_initialized == 1) {

iret = pthread_tryjoin_np(

h_process_command_thread,

NULL

);

if ((iret != 0) && (iret != EBUSY)) {

//TODO: process the error

}

if (iret == EBUSY) {

clock_gettime(CLOCK_REALTIME, &wait_time);

ADD_MS_TO_TIMESPEC(wait_time, 5000);

iret = pthread_timedjoin_np(

h_process_command_thread,

NULL,

&wait_time

);

switch (iret) {

case 0:

// everything from this point on is good

break;

case ETIMEDOUT:

case EINVAL:

default:

break;

}

}

}

#endif //__PL_LINUX__

細心的讀者會注意到ADD_MS_TO_TIMESPEC是 Linux 操作系統中未表示的宏。 宏被添加到wait_time5000毫秒，但宏實現不在本文的討論范圍之內。還應該提到的是，在 Linux 中我們需要引入一個單獨的變量h_process_command_thread_initialized，因為pthread_t是無符號的 long（一般來說），我們無法驗證它。

讓我們總結一下結果。Linux 和 Windows 操作系統提供了在應用程序內部創建線程的機會。在Windows操作系統中，類型是HANDLE和Linux-pthread_t。如果在 Linux 操作系統中創建可連接線程，即使我們確定線程已終止，也有必要編寫pthread_join。這種做法將幫助我們避免系統資源泄漏。

討論的功能記錄在表 1 中。

Linux函數	窗口函數
pthread_create	開始線程
pthread_join	WaitForSingleObject（..， INFINITE）
pthread_timedjoin_np	GetExitCodeThreadWaitForSingleObject
pthread_tryjoin_np	獲取退出代碼線程

表 1.Windows 和 Linux 操作系統中的線程同步函數。

事件

事件是內核對象變體的實例。事件通知操作終止，通常在線程執行初始化，然后向另一個線程發出可以繼續工作的信號時使用。初始化線程將 ?event? 對象轉換為無信號狀態，然后繼續其操作。完成后，它將事件釋放到信號狀態。反過來，一直在等待事件將其狀態更改為信號的另一個線程恢復并再次成為計劃線程。

讓我們來看看在Windows和Linux操作系統中處理“事件”對象的函數。

在Windows操作系統中，使用CreateEvent函數創建一個“事件”對象：

HANDLE CreateEvent(

PSECURITY_ATTRIBUTES psa,

BOOL fManualReset,

BOOL fInitialState,

PCSTR pszName

);

讓我們更清楚地關注fManualReset和fInitialState參數。BOOL類型的FManualReset參數通知系統需要創建手動重置事件 （TRUE）或自動重置事件 （FALSE）。fInitialState參數確定事件的初始狀態：已發出信號 （TRUE）或未發出信號 （FALSE）。

創建事件后，可以管理狀態。要將事件轉換為信號狀態，您需要調用：

Bool SetEvent（HANDLE hEvent）;

若要將事件狀態更改為無信號，需要調用：

Bool ResetEvent（HANDLE hEvent）;

要等待事件信號，您需要使用我們已經熟悉的WaitForSingleObject函數。

在Linux操作系統中，“事件”對象表示整數描述符。一個整數 ?event? 對象是使用eventfd函數創建的：

int eventfd（unsigned int initval， int flags）;

initval參數是一個內核服務計數器。flags參數是eventfd行為修改所必需的，可以是EFD_CLOEXEC、EFD_NONBLOCK或EFD_SEMAPHORE。如果成功終止，eventfd將返回一個新的文件描述符，該描述符可用于鏈接eventfd對象。

與SetEvent類似，我們可以使用eventfd_write調用：

ssize_t eventfd_write（int fd， const void *buf， size_t count）;

從緩沖區調用寫入時，會將 8 字節整數值添加到計數器中。最大計數器值可以是 64 位無符號減 1。如果函數調用成功，則返回寫入的字節數。

在我們討論ResetEvent類似物之前，讓我們看一下輪詢函數。

#include

int poll（struct pollfd fdarray[]， nfds_t nfds， int timeout）;

輪詢功能允許應用程序同時阻止多個描述符，并在其中任何一個準備好讀取或寫入時立即接收通知。民意調查工作（一般）可以描述如下：

當任何描述符準備好進行輸入-輸出操作時發出通知。

如果沒有任何描述符準備就緒，請進入睡眠模式，直到一個或多個描述符準備就緒。

如果有可用的描述符準備用于輸入-輸出，請處理它們而不會阻塞。

返回到步驟 1。

Linux 操作系統為多路復用輸入輸出提供了三個實體：用于選擇（選擇）、輪詢（輪詢）、擴展輪詢（epoll）的接口。

那些有使用select經驗的人可能會欣賞投票的優勢，它使用更有效的方法，基于位掩碼使用三組描述符。輪詢調用適用于文件描述符指向的單個nfdspollfd結構數組。

讓我們看一下pollfd結構定義：

struct pollfd {

int fd; /* file descriptor */

short events; /* requested events */

short revents; /* returned events */

};

每個pollfd結構中都指示了一個將被跟蹤的文件描述符?？梢詫⒍鄠€文件描述符傳遞給輪詢函數（結構的 pollfd數組）。fdarray數組中的元素數由nfds參數確定。

為了將我們感興趣的事件傳達給內核，有必要在數組中每個元素的事件字段中寫入表 2 中的一個或多個值。從輪詢函數返回后，內核指定每個描述符發生的事件。

名字	事件	活動	描述
波林	+	+	數據可供讀?。ǜ邇炏燃壋猓?/td>
波爾德規范	+	+	常規數據（優先級 0）可供讀取
波爾德班德	+	+	具有非零優先級的數據可供讀取
波普里普里	+	+	高優先級數據可供讀取
波羅特	+	+	數據可供寫入
波爾沃諾姆	+	+	類似于 波勞特
民意調查帶	+	+	具有非零優先級的數據可用于寫入
波勒爾		+	發生錯誤
波爾赫普		+	連接丟失
波倫瓦爾		+	描述符和打開的文件不匹配

表 2.事件和輪詢函數的revents標志的可能值。

參數超時定義發生指定事件的等待時間。超時有三種可能的值。

timeout= -1：等待時間是無限的（在 WaitForSingleObject中為 INFINITE）。

timeout= 0：等待時間等于 0，表示需要檢查所有指定的描述符并將控制權交還給調用程序。

超時> 0：等待時間不超過超時毫秒。

在查看了輪詢函數之后，我們可以得出結論，在Windows操作系統中，“事件”對象與WaitForSingleObject類似。

讓我們轉到 Linux 的ResetEvent類似物。

#ifdef __PL_LINUX__

struct pollfd wait_object;

uint64_t event_value;

int ret;

if (eventfd_descriptor > 0) { // Descriptor created by eventfd(0,0)

wait_object.fd = eventfd_descriptor;

wait_object.events = POLLIN;

wait_object.revents = 0;

ret = poll(&wait_object, 1, 0); // Do not wait

if (ret < 0) { // Error

} else {

if ((wait_object.revents & POLLIN) != 0) {

iret = eventfd_read(eventfd_descriptor, &event_value);

if (iret != 0) { // Error }

}

}

}

#endif //__PL_LINUX__

最初我們檢查eventfd_descriptor是否大于零[2]（實際上，這最初是由eventfd函數創建的，沒有錯誤）。之后，我們初始化pollfd函數并運行輪詢。需要執行輪詢以檢查是否有可用的數據可供讀取。如果有此類數據，我們將讀取它。

通過上述所有內容的鏡頭，讓我們反映表3中的結果：

窗口函數	Linux函數
創建事件	事件FD
設置事件	eventfd_write
重置事件	投票/eventfd_read
等待單個對象	民意調查

表 3.用于處理 Windows 中的事件及其在 Linux 中的類似事件的主要函數。

審核編輯：郭婷