描述python实现读写锁rwlock及场景

读写锁比mutex有更高的适用性,可以多个线程同时占用读模式的读写锁,但是只能一个线程占用写模式的读写锁;

1,当读写锁是写加锁状态时, 在这个锁被解锁之前, 所有试图对这个锁加锁的线程都会被阻塞.

2,当读写锁在读加锁状态时, 所有试图以读模式对它进行加锁的线程都可以得到访问权,但是以写模式对它进行枷锁的线程将阻塞;

3,当读写锁在读模式锁状态时, 如果有另外线程试图以写模式加锁, 读写锁通常会阻塞随后的读模式锁请求, 这样可以避免读模式锁长期占用, 而等待的写模式锁请求长期阻塞.

文章后期会有修改,请到原文链接查看更新   http://xiaorui.cc/?p=2384

这种锁适用对数据结构进行读的次数比写的次数多的场景下.

import threading
class ReadWriteLock(object):

    def __init__(self):
        self.__monitor = threading.Lock()
        self.__exclude = threading.Lock()
        self.readers = 0


    def acquire_read(self):
        with self.__monitor:
            self.readers += 1
            if self.readers == 1:
                self.__exclude.acquire()
                
    def release_read(self):
        with self.__monitor:
            self.readers -= 1
            if self.readers == 0:
                self.__exclude.release()


    def acquire_write(self):
        self.__exclude.acquire()
                
    def release_write(self):
        self.__exclude.release()

其实读写锁,也分读优先和写优先的.


读优先: 即同时有多个读写线程在等待一个条件时,先处理读,后处理写。

实现:写进程获得写锁时,先判断读的引用计数,若0,则继续判断是否有其他线程已获得写权限,若有则循环等待阻塞等待至无,然后继续判断读的引用计数然后继续判断写权限,直至无,然后才对写加锁, 读线程,先对引用计数加1,然后才去判断写的引用计数,如果无,则等待释放写锁,然后继续读

写优先: 即同时有多个读写线程在等待一个条件时,先处理写,然后处理读

实现:写线程获得写锁时,先判断是写的引用计数,若无,则增加,然后判断读的引用计数,等待读线程的引用计数为0(此时,读线程的引用计数是在判断无线程写时后才增加的),则进行写,但这样实现不了写优先,写和读都是在同时竞争,可以让同时两个写线程增加写的引用计数,即一个写线程写,一个写线程等待,这样可使读线程的读锁一直获取不到, 读线程,先判断写的引用计数,若不为0,则等待其为0,然后进行读.

读优先优缺点:即写线程等待无线程读时才更新共享数据,这样读效率略高,但对于读的数据实时性不高,如果一直有线程请求读,则写线程会饿死

写优先优缺点:即写线程可在等当前读的线程处理结束,就可更新共享数据,这样效率略低,但对于读的数据实时性高.


大家觉得文章对你有些作用! 如果想赏钱,可以用微信扫描下面的二维码,感谢!
另外再次标注博客原地址  xiaorui.cc

发表评论

邮箱地址不会被公开。 必填项已用*标注