一、读写锁
1.介绍
读写锁(ReadWrite Locks,也称为共享-互斥锁)是一个用于同步访问的机制,允许多个读取者同时访问同一资源,但在任何时候只允许一个写入者。这通常用于数据结构(如列表、数组或散列表)的并发访问,其中读取操作比写入操作频繁得多。
在 POSIX 线程(Pthreads)库中,你可以使用 pthread_rwlock_t
类型的变量表示读写锁,使用 pthread_rwlock_init
来初始化或者PTHREAD_RWLOCK_INITIALIZER初始化静态的锁,pthread_rwlock_destroy
来销毁。以下是一些基本的操作:
pthread_rwlock_rdlock
:获取读锁。如果有其他线程持有写锁,或者有其他线程正在等待获取写锁,那么这个函数会阻塞,直到可以安全地获取读锁为止。pthread_rwlock_wrlock
:获取写锁。如果有其他线程持有读锁或写锁,那么这个函数会阻塞,直到可以安全地获取写锁为止。pthread_rwlock_unlock
:释放读锁或写锁。
#include pthread_rwlock_t lock;void read_data() {pthread_rwlock_rdlock(&lock);// 读取数据的代码pthread_rwlock_unlock(&lock);}void write_data() {pthread_rwlock_wrlock(&lock);// 写入数据的代码pthread_rwlock_unlock(&lock);}
在这个例子中,read_data
函数获取读锁,然后读取数据,最后释放锁。write_data
函数获取写锁,写入数据,然后释放锁。使用读写锁可以使多个读取者并行访问数据,但在写入数据时,仍然只有一个写入者可以访问数据,确保数据的一致性。
2.函数原型
创建读写锁:
int pthread_rwlock_init(pthread_rwlock_t *restrict rwlock, const pthread_rwlockattr_t *restrict attr);
参数:
pthread_rwlock_t *restrict rwlock
:指向将被初始化的读写锁的指针。const pthread_rwlockattr_t *restrict attr
:指向读写锁属性对象的指针,该对象可以用于设置读写锁的属性。如果传入 NULL,则使用默认的属性。
返回值:如果成功,返回 0;否则,返回一个错误码。
销毁读写锁:
int pthread_rwlock_destroy(pthread_rwlock_t *rwlock);
参数:
pthread_rwlock_t *rwlock
:指向需要销毁的读写锁的指针。
返回值:如果成功,返回 0;否则,返回一个错误码。
使用读写锁:
获取读锁:
int pthread_rwlock_rdlock(pthread_rwlock_t *rwlock);
参数:
pthread_rwlock_t *rwlock
:指向需要获取读锁的读写锁的指针。
返回值:如果成功,返回 0;否则,返回一个错误码。
获取写锁:
int pthread_rwlock_wrlock(pthread_rwlock_t *rwlock);
参数:
pthread_rwlock_t *rwlock
:指向需要获取写锁的读写锁的指针。
返回值:如果成功,返回 0;否则,返回一个错误码。
解锁:
int pthread_rwlock_unlock(pthread_rwlock_t *rwlock);
参数:
pthread_rwlock_t *rwlock
:指向需要解锁的读写锁的指针。
返回值:如果成功,返回 0;否则,返回一个错误码。
需要注意的是,任何成功地调用了 pthread_rwlock_rdlock
或 pthread_rwlock_wrlock
的线程都必须在不需要锁的时候调用 pthread_rwlock_unlock
。如果同一个线程多次调用 pthread_rwlock_rdlock
或 pthread_rwlock_wrlock
,就可能会导致死锁。此外,试图解锁一个已经被其他线程持有的锁,或者未被任何线程持有的锁,都是未定义的行为。
3.例子
#include #include #define NUM_READER_THREADS 5pthread_rwlock_t rwlock;int counter = 0; // 共享资源void *reader(void *arg) {pthread_rwlock_rdlock(&rwlock);printf("Reader: counter = %d\n", counter);pthread_rwlock_unlock(&rwlock);return NULL;}void *writer(void *arg) {pthread_rwlock_wrlock(&rwlock);counter++;printf("Writer: counter = %d\n", counter);pthread_rwlock_unlock(&rwlock);return NULL;}int main() {pthread_t reader_threads[NUM_READER_THREADS], writer_thread;pthread_rwlock_init(&rwlock, NULL);pthread_create(&writer_thread, NULL, writer, NULL);for (int i = 0; i < NUM_READER_THREADS; i++) {pthread_create(&reader_threads[i], NULL, reader, NULL); }pthread_join(writer_thread, NULL);for (int i = 0; i < NUM_READER_THREADS; i++) {pthread_join(reader_threads[i], NULL); }pthread_rwlock_destroy(&rwlock);return 0;}
需要注意对于线程相关代码的编译需要链接上posix线程库:gcc xxx.c -lpthread -l是链接选项,pthread是库名称,默认不添加空格也可以添加空格gcc xxx.c -l pthread
二、带超时机制的读写锁
1.介绍
POSIX 线程库提供了两个函数,用于带有超时机制的读写锁操作:
pthread_rwlock_timedrdlock
:尝试获取读锁,如果在指定的时间内无法获取,则返回超时错误。pthread_rwlock_timedwrlock
:尝试获取写锁,如果在指定的时间内无法获取,则返回超时错误。
这两个函数的函数原型如下:
int pthread_rwlock_timedrdlock(pthread_rwlock_t *restrict rwlock,const struct timespec *restrict abs_timeout);
参数:
pthread_rwlock_t *restrict rwlock
:指向要获取读锁的读写锁的指针。const struct timespec *restrict abs_timeout
:指向timespec
结构的指针,该结构定义了一个绝对时间,用于指定超时的时间点。如果在这个时间点之前还不能获取读锁,函数会返回一个超时错误。
返回值:如果成功,返回 0;否则,返回一个错误码。如果超时,返回 ETIMEDOUT
。
int pthread_rwlock_timedwrlock(pthread_rwlock_t *restrict rwlock,const struct timespec *restrict abs_timeout);
参数:
pthread_rwlock_t *restrict rwlock
:指向要获取写锁的读写锁的指针。const struct timespec *restrict abs_timeout
:同上,用于指定超时的时间点。
返回值:同上。
这两个函数都使用了 timespec
结构来表示超时的时间点,该结构有两个成员:tv_sec
和 tv_nsec
,分别表示秒和纳秒。这个时间表示的是一个绝对时间,即从某个固定的时间点(如 Unix 纪元,1970 年 1 月 1 日)开始的时间。
需要注意的是,pthread_rwlock_timedrdlock
和 pthread_rwlock_timedwrlock
这两个函数在 POSIX 标准中是可选的,因此,一些系统可能不支持这两个函数。你应该检查你的系统文档,看看这些函数是否可用。