forked from lihongchao/threadpool
-
Notifications
You must be signed in to change notification settings - Fork 0
Expand file tree
/
Copy pathlocker.h
More file actions
113 lines (107 loc) · 2.07 KB
/
Copy pathlocker.h
File metadata and controls
113 lines (107 loc) · 2.07 KB
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
#ifndef LOCKER_H
#define LOCKER_H
#include <exception>
#include <pthread.h>
#include <semaphore.h>
class sem
{
public:
/*封装信号量的类*/
sem()
{
if( sem_init( &m_sem, 0, 0 ) != 0 )
{
/*构造函数没有返回值，可以通过抛出异常来报告错误*/
throw std::exception();
}
}
/*销毁信号量*/
~sem()
{
sem_destroy( &m_sem );
}
/*等待信号量*/
bool wait()
{
return sem_wait( &m_sem ) == 0;
}
/*增加信号量*/
bool post()
{
return sem_post( &m_sem ) == 0;
}
private:
sem_t m_sem;
};
/*封装互斥锁的类*/
class locker
{
public:
/*创建并初始化互斥锁*/
locker()
{
if( pthread_mutex_init( &m_mutex, NULL ) != 0 )
{
throw std::exception();
}
}
/*销毁互斥锁*/
~locker()
{
pthread_mutex_destroy( &m_mutex );
}
/*获取互斥锁*/
bool lock()
{
return pthread_mutex_lock( &m_mutex ) == 0;
}
/*释放互斥锁*/
bool unlock()
{
return pthread_mutex_unlock( &m_mutex ) == 0;
}
private:
pthread_mutex_t m_mutex;
};
/*封装条件变量*/
class cond
{
public:
/*创建并初始化条件变量*/
cond()
{
if( pthread_mutex_init( &m_mutex, NULL ) != 0 )
{
throw std::exception();
}
if ( pthread_cond_init( &m_cond, NULL ) != 0 )
{
pthread_mutex_destroy( &m_mutex );
throw std::exception();
}
}
/*销毁条件变量*/
~cond()
{
pthread_mutex_destroy( &m_mutex );
pthread_cond_destroy( &m_cond );
}
/*等待条件变量*/
bool wait()
{
int ret = 0;
pthread_mutex_lock( &m_mutex );
ret = pthread_cond_wait( &m_cond, &m_mutex );
pthread_mutex_unlock( &m_mutex );
return ret == 0;
}
/*唤醒等待条件变量的线程*/
bool signal()
{
return pthread_cond_signal( &m_cond ) == 0;
}
private:
pthread_mutex_t m_mutex;
pthread_cond_t m_cond;
};
#endif