Android同步类:Mutex和Condition的使用方式

Android同步类:Mutex和Condition的使用方式

Metux类

Mutex是互斥类,多个线程访问同一个资源时,要确保他们的互斥。主要函数有
lock(),unlock(),trylock()


函数名 作用
lock() 当使用lock函数时,当前的线程就会lock住;如果有线程已经锁住,lock()则会等待直到成功为止,系统只允许有一个线程被lock住
unlock() 该函数可以释放线程
trylock() 该函数尝试去锁进程,通过返回值可以判断是否能lock住

以下是Mutex的源码

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
inline Mutex::Mutex(int type, const char* name) {
if (type == SHARED) {
//type如果是SHARED,则表明这个Mutex支持跨进程的线程同步。
pthread_mutexattr_t attr;
pthread_mutexattr_init(&attr);
pthread_mutexattr_setpshared(&attr, PTHREAD_PROCESS_SHARED);
pthread_mutex_init(&mMutex, &attr);
pthread_mutexattr_destroy(&attr);
} else {
pthread_mutex_init(&mMutex, NULL);
}
}
inline Mutex::~Mutex() {
pthread_mutex_destroy(&mMutex);
}
inline status_t Mutex::lock() {
return -pthread_mutex_lock(&mMutex);
}
inline void Mutex::unlock() {
pthread_mutex_unlock(&mMutex);
}
inline status_t Mutex::tryLock() {
return -pthread_mutex_trylock(&mMutex);
}

AutoLock类

AutoLock类是Mutex的一个内部类,是为了方便使用Mutex而产生的。
在Mutex中,lock和unlock是必须成对出现的,但是当代码很复杂时,则会出现遗漏的现象。
利用构造和析构函数的性质,可以方便地让lock和unlock成对出现。
当需要使用lock函数时,构造一个AutoLock类,线程结束后该类析构,则相当于unlock,这样避免了发生lock和unlock不匹配的情况。

以下是Autolock的源码

1
2
3
4
5
6
7
8
9
10
class Autolock {
public:
//构造的时候调用lock。
inline Autolock(Mutex& mutex) : mLock(mutex) { mLock.lock(); }
inline Autolock(Mutex* mutex) : mLock(*mutex) { mLock.lock(); }
//析构的时候调用unlock。
inline ~Autolock() { mLock.unlock(); }
private:
Mutex& mLock;
};

Condition类

线程B或者C在运行前,必须有一个A线程的初始化,即A是一个条件,Condition则是用在这样的一种场景中,并且Condition和Mutex是配合使用的,Condition的函数都必须放在Mutex的lock和unlock之间。


函数名 作用
wait(Mutex& mutex) 线程B和C等待事件
waitRelative(Mutex& mutex, nsecs_t reltime) 线程B和C的超时等待,B和C可以指定等待时间,当超过这个时间,条件却还不满足,则退出等待。
signal() 触发者A用来通知条件已经满足,但是B和C只有一个会被唤醒。
broadcast() 触发者A用来通知条件已经满足,所有等待者都会被唤醒。(广播)

以下是Condition的源码

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
class Condition {
public:
enum {
PRIVATE = 0,
SHARED = 1
};


Condition();
Condition(int type);//如果type是SHARED,表示支持跨进程的条件同步
~Condition();

status_t wait(Mutex& mutex);

status_t waitRelative(Mutex& mutex, nsecs_t reltime);

void signal();

void broadcast();


private:
#if defined(HAVE_PTHREADS)
pthread_cond_t mCond;
#else
void* mState;
#endif
}
文章目录
  1. 1. Metux类
  2. 2. AutoLock类
  3. 3. Condition类