多线程的那点儿事(之多线程数据结构)
2023-09-27 14:27:10 时间
【 声明:版权所有,欢迎转载,请勿用于商业用途。 联系信箱:feixiaoxing @163.com】
总结:
(1) 一般来说,比较好的数据结构要兼有多线程和没有多线程两种情况
(2) 如果需要用其他的锁代替mutex,直接换掉就可以,十分方便
要想编写多线程,那就要使用锁。而在软件编写中,数据结构是少不了的。所以,我们在编写多线程的时候,就需要考虑一下如何在数据结构中插入锁。当然,有些数据结构是没有锁的,所以自然这个锁并不一定是必须的。
比如说,我们编写一个多线程堆栈,应该怎么做呢,
typedef struct _STACK
{
void* pData;
int maxLen;
int top;
void* hLock;
STATUS (*push)(struct _STACK* pStack, void* pData, int size);
STATUS (*pop)(struct _STACK* pStack, void* pData, int size);
}STACK;
(1) 初始化操作
STACK* get_new_stack(void* pData, int len, void* pLock)
{
STACK* pStack;
if(NULL == pData || 0 == len)
return NULL;
pStack = (STACK*)malloc(sizeof(STACK));
assert(NULL != pStack);
memset(pStack, 0, sizeof(STACK));
pStack->pData = pData;
pStack->maxLen = len;
if(NULL != pLock)
pStack->hLock = pLock;
return pStack;
}
(2) 添加数据
STATUS push(struct _STACK* pStack, void* pData, int size)
{
assert(NULL != pStack && NULL != pData);
if(NULL != pStack->hLock)
WaitForSingleObject((HANDLE)pStack->hLock, INFINITE);
if(pStack->top == pStack->maxLen){
if(NULL != pStack->hLock)
ReleaseMutex((HANDLE)pStack->hLock);
return ERROR;
}
memmove((char*)pStack->pData + size * pStack->top, (char*)pData, size);
pStack->top ++;
if(NULL != pStack->hLock)
ReleaseMutex((HANDLE)pStack->hLock);
return OK;
}
(3) 对2进行优化,因为判断的条件比较复杂
#define STACK_CHECK_LOCK(hLock) \
do{\
if(hLock)\
WaitForSingleObject((HANDLE)hLock, INFINITE);\
}while(0)
#define STACK_CHECK_UNLOCK(hLock) \
do{\
if(hLock)\
ReleaseMutex((HANDLE)hLock);\
}while(0)
所以,2的代码可以修改为,
STATUS push(struct _STACK* pStack, void* pData, int size)
{
assert(NULL != pStack && NULL != pData);
STACK_CHECK_LOCK(pStack->hLock);
if(pStack->top == pStack->maxLen){
STACK_CHECK_UNLOCK(pStack->hLock);
return ERROR;
}
memmove((char*)pStack->pData + size * pStack->top, (char*)pData, size);
pStack->top ++;
STACK_CHECK_UNLOCK(pStack->hLock);
return OK;
}
总结:
(1) 一般来说,比较好的数据结构要兼有多线程和没有多线程两种情况
(2) 如果需要用其他的锁代替mutex,直接换掉就可以,十分方便
相关文章
- 多线程编程学习笔记——线程池(三)
- Java多线程之线程同步
- c# .net 模拟请求 POST, Get,Put,Delete,并带Headers,BUF加持异步多线程执行
- 《Java并发性和多线程介绍》-Java TheadLocal
- 多线程都调用一个函数,在这个函数中的一个局部变量什么情况会被修改
- MFC不能多线程操作控件的原因
- 多线程中的Lock小结
- 多线程编程(一) - 关于C#中Thread.Join()
- 创建多线程类
- Swift - 多线程实现方式(2) - NSOperation和NSOperationQueue
- 多线程的数据结构
- 网络I/O模型--04非阻塞模式(解除accept()、 read()方法阻塞)的基础上加入多线程技术
- Linux多线程编程-信号量
- 30网络通信之多线程
- 4创建型模式之单例模式__多线程下的懒汉式单例和饿汉式单例
- Java多线程、进程、并发与并行的含义
- Java多线程-synchronized同步方法及同步块简述
- 多线程DP