Win32 POSIX编程-Task篇

最近想把公司的DLNA平台代码 (DMS DMP)移植到Windows平台。
【Win32 POSIX编程-Task篇】考虑到对windows内核不熟悉,打算继续用POSIX API。


准备工作:
开发平台: WINXP + VS2008 + Phread for Win32 (http://www.sourceware.org/pthreads-win32/)


接口设计:
OS_TASK_Handle OS_TASK_Creat(
API_IN XPCHAR taskname, // 线程名称,Debug用
API_IN OS_TASK_Func pFunc, // 任务函数
API_IN void *userData, // 用户数据
API_IN xuint stackSize // 栈空间大小
);


OS_RET OS_TASK_Start(
API_IN OS_TASK_Handle handle
);


OS_RET OS_TASK_Stop(
API_IN OS_TASK_Handle handle
);


OS_RET OS_TASK_StopWithCond(
API_IN OS_TASK_Handle handle,
API_IN void* pCond // 结束条件
);


XBOOL OS_TASK_IsRunable(
API_IN OS_TASK_Handle handle
);


OS_RET OS_TASK_Destroy(
API_IN OS_TASK_Handle handle
);


void * OS_TASK_GetUserData( // 主要用于任务函数中获取用户数据
API_IN OS_TASK_Handle handle
);



实现探讨:
1 OS_TASK_Start
pthread_attr_t thread_attr;

pthread_attr_init(&thread_attr);
pthread_attr_setdetachstate(&thread_attr, PTHREAD_CREATE_DETACHED); // 采用分离模式, 默认是PTHREAD _CREATE_JOINABLE
pthread_attr_setstacksize (&thread_attr,pTaskHandle->stackSize); // 设置Stack 大小。


if (pthread_create(&pTaskInfo->pThread, &thread_attr, PosixThreadProc, pTaskHandle) != 0) { //pTaskHandle 是OS_TASK_Handle的实现封装
pTaskHandle->runnableFlag = XFALSE;
pthread_attr_destroy(&thread_attr);
return S_FAILURE;
}
pthread_attr_destroy(&thread_attr);
pTaskHandle->runnableFlag = XTRUE;



PosixThreadProc函数实现:

由于Phread for Win32 下载版本不支持Signal,为了简单,只能把linxu版本的设置信号相关代码删除。
#if ndef WIN32
sigfillset(&set);
sigdelset(&set, SIGQUIT);
pthread_sigmask(SIG_SETMASK, &set, NULL);

memset(&actions, 0, sizeof(actions));
sigemptyset(&actions.sa_mask);
actions.sa_flags = 0;
actions.sa_handler = sig_handler;
sigaction(SIGQUIT, &actions, NULL);

#endif

pthread_once(&xos_thread_mykeycreated, xos_thread_createkey); //一次性初始化
pthread_setspecific(xos_thread_self_ref, param);

if (thread->action != NULL)
thread->action(thread);



2OS_TASK_StopWithCond
先判断线程状态,如果已经启动,则发送SIGNAL,并调用pthread_kill结束线程。为了安全,再睡眠一段时间。


if (pTaskHandle->runnableFlag == XTRUE) {
pTaskHandle->runnableFlag = XFALSE;
if (pCond != NULL) {
OS_Cond_Signal((OS_Cond_Handle)pCond);
}


XLOG_Debug_L4("Killing thread %p\n", pTaskInfo->pThread);


#ifdef WIN32
pthread_kill(pTaskInfo->pThread, 0);
#else
pthread_kill(pTaskInfo->pThread, SIGQUIT);
#endif



    推荐阅读