创建线程不接受成员函数

Question

我正在尝试为网络编程创建一个类。这将创建一个带有线程的通用套接字。

但是当我尝试使用 createthread() 来创建线程时。第三个论点是产生错误。从网上我知道我不能使用成员函数作为 createthread() 的参数。

我有什么办法可以做到这一点吗？

Answer 1

处理此问题的最简单方法是创建一个“存根”函数，该函数回调到您的类中。

UINT tid
HANDLE hThread = CreateThread(NULL, 0, myThreadStub, this, 0, &tid);

....

unsigned long WINAPI myThreadStub(void *ptr) 
{
    if (!ptr) return -1;
    return ((MyClass*)ptr)->ThreadMain();
}

CreateThread() 允许您将参数传递给线程函数（CreateThread() 调用的参数 4）。您可以使用它来传递指向您的类的指针。然后，您可以让线程存根将该指针转换回正确的类型，然后调用成员函数。你甚至可以让“myThreadStub”成为“MyClass”的static成员，允许它 访问私有成员和数据。

如果您安装了 boost，则可以使用 boost::bind 来执行此操作，而无需创建存根函数。我从来没有在 Windows 上尝试过，所以我不能肯定它会起作用（因为回调函数必须是 WINAPI 调用）但如果它确实起作用，它看起来像：

HANDLE hThread = CreateThread(NULL, 0, boost::bind(&MyClass::ThreadFunction, this), NULL, 0, &tid);

其中线程函数是一个非静态成员函数，它接受一个 void * 参数。

Answer 2

有一个简单的方法可以解决这个问题。

看看ThreadProc callback function：

DWORD WINAPI ThreadProc( __in LPVOID lpParameter );

现在CreateThread function:

处理 WINAPI CreateThread( __in_opt LPSECURITY_ATTRIBUTES lpThreadAttributes， __in SIZE_T dwStackSize, __in LPTHREAD_START_ROUTINE lpStartAddress, __in_opt LPVOID lpParameter, __in DWORD dwCreationFlags, __out_opt LPDWORD lpThreadId );

使用静态方法作为线程过程，但从成员方法中调用它，并将对象指针传递给它：

#include 我的班级{ 上市： 无效 CreateThreadForObject() { LPSECURITY_ATTRIBUTES security_attributes = 0; SIZE_T stack_size = 0; LPTHREAD_START_ROUTINE start_routine = &MyClass::ThreadProcForObject; LPVOID 参数 = this; DWORD 创建标志 = 0; LPDWORD thread_id = 0; CreateThread(security_attributes, stack_size, start_routine, param, 创建标志，线程ID）； } 私人的： 静态 DWORD WINAPI ThreadProcForObject(LPVOID 参数) { MyClass* instance = reinterpret_cast(param); 如果（！实例）返回1； // ... 返回0； } };

对不起，我只是没有足够的时间来写一个好的例子。但我想你理解的方式。

Answer 3

迷路了，我明白了，事实上，在CreateThread中，如果你通过了socket，那么就没有问题了。因为 CreateThread 正在 照顾 该 socket。但是，如果您作为具有该 socket 的对象传递，那么 CreateThread 将 不关心 socket ，并在 新线程 中以 invalid socket 结束。

下面的成功代码

SOCKET s=socket(....);
bind(s,...);
listen(s,...);
SOCKET temp=accept(s,(sockaddr *)&addrNew,&size);
DWORD threadId;
HANDLE thread=CreateThread(NULL,0,&MyThreadFunction,(LPVOID)(temp),0,&threadId);