我正在为 Linux 平台实现多线程 C++ 程序,其中我需要类似于 WaitForMultipleObjects() 的功能。
在搜索解决方案时,我发现有一些文章描述了如何在 Linux 中实现 WaitForMultipleObjects() 功能,并附有示例,但这些示例不满足我必须支持的场景。
我的情况非常简单。我有一个守护进程,其中主线程向外界公开方法/回调,例如向 DLL 公开。 DLL 的代码不在我的控制之下。同一个主线程创建一个新线程“Thread 1”。线程 1 必须执行一种无限循环,其中它将等待关闭事件(守护程序关闭),或者等待通过上述公开的方法/回调发出信号的数据可用事件。
简而言之,线程将等待关闭事件和数据可用事件,其中如果发出关闭事件信号,则等待将满足并且循环将被打破,或者如果发出数据可用事件信号,则等待也将满足并且线程将进行业务处理。
在 Windows 中,它看起来非常简单。下面是针对我的场景的基于 MS Windows 的伪代码。
//**Main thread**
//Load the DLL
LoadLibrary("some DLL")
//Create a new thread
hThread1 = __beginthreadex(..., &ThreadProc, ...)
//callback in main thread (mentioned in above description) which would be called by the DLL
void Callbackfunc(data)
{
qdata.push(data);
SetEvent(s_hDataAvailableEvent);
}
void OnShutdown()
{
SetEvent(g_hShutdownEvent);
WaitforSingleObject(hThread1,..., INFINITE);
//Cleanup here
}
//**Thread 1**
unsigned int WINAPI ThreadProc(void *pObject)
{
while (true)
{
HANDLE hEvents[2];
hEvents[0] = g_hShutdownEvent;
hEvents[1] = s_hDataAvailableEvent;
//3rd parameter is set to FALSE that means the wait should satisfy if state of any one of the objects is signaled.
dwEvent = WaitForMultipleObjects(2, hEvents, FALSE, INFINITE);
switch (dwEvent)
{
case WAIT_OBJECT_0 + 0:
// Shutdown event is set, break the loop
return 0;
case WAIT_OBJECT_0 + 1:
//do business processing here
break;
default:
// error handling
}
}
}
我想在 Linux 上实现同样的功能。根据我的理解,当涉及到Linux时,它有完全不同的机制,我们需要注册信号。如果终止信号到达,进程就会知道它即将关闭,但在此之前,进程必须等待正在运行的线程正常关闭。