July 2002
Intermediate to advanced
608 pages
15h 46m
English
Credit: Sami Hangaslammi
You need to allow unlimited read access to a resource when it is not being modified while keeping write access exclusive.
“One-writer, many-readers” locks are a frequent necessity, and Python does not supply them directly. As usual, they’re not hard to program yourself, in terms of other synchronization primitives that Python does supply:
import threading
class ReadWriteLock:
""" A lock object that allows many simultaneous "read locks", but
only one "write lock." """
def _ _init_ _(self):
self._read_ready = threading.Condition(threading.Lock( ))
self._readers = 0
def acquire_read(self):
""" Acquire a read lock. Blocks only if a thread has
acquired the write lock. """
self._read_ready.acquire( )
try:
self._readers += 1
finally:
self._read_ready.release( )
def release_read(self):
""" Release a read lock. """
self._read_ready.acquire( )
try:
self._readers -= 1
if not self._readers:
self._read_ready.notifyAll( )
finally:
self._read_ready.release( )
def acquire_write(self):
""" Acquire a write lock. Blocks until there are no
acquired read or write locks. """
self._read_ready.acquire( )
while self._readers > 0:
self._read_ready.wait( )
def release_write(self):
""" Release a write lock. """
self._read_ready.release( )It is often convenient to allow unlimited read access to a resource
when it is not being modified and still keep write access exclusive.
While the threading