summaryrefslogtreecommitdiffstats
path: root/Lib/mutex.py
diff options
context:
space:
mode:
authorTim Peters <tim.peters@gmail.com>2001-01-14 23:47:14 (GMT)
committerTim Peters <tim.peters@gmail.com>2001-01-14 23:47:14 (GMT)
commit07e99cb77406e1bc84606f49b743e41b0de8a6d5 (patch)
treeb922cda3a970bffa797269fd550f8d8b032afe5b /Lib/mutex.py
parent88869f9787cd4ceb2298e4b13980beb057687824 (diff)
downloadcpython-07e99cb77406e1bc84606f49b743e41b0de8a6d5.zip
cpython-07e99cb77406e1bc84606f49b743e41b0de8a6d5.tar.gz
cpython-07e99cb77406e1bc84606f49b743e41b0de8a6d5.tar.bz2
Whitespace normalization.
Diffstat (limited to 'Lib/mutex.py')
-rw-r--r--Lib/mutex.py64
1 files changed, 32 insertions, 32 deletions
diff --git a/Lib/mutex.py b/Lib/mutex.py
index 9271d34..2348a2e 100644
--- a/Lib/mutex.py
+++ b/Lib/mutex.py
@@ -13,39 +13,39 @@ for lock, where a function is called once the lock is aquired.
"""
class mutex:
- def __init__(self):
- """Create a new mutex -- initially unlocked."""
- self.locked = 0
- self.queue = []
+ def __init__(self):
+ """Create a new mutex -- initially unlocked."""
+ self.locked = 0
+ self.queue = []
- def test(self):
- """Test the locked bit of the mutex."""
- return self.locked
+ def test(self):
+ """Test the locked bit of the mutex."""
+ return self.locked
- def testandset(self):
- """Atomic test-and-set -- grab the lock if it is not set,
- return true if it succeeded."""
- if not self.locked:
- self.locked = 1
- return 1
- else:
- return 0
+ def testandset(self):
+ """Atomic test-and-set -- grab the lock if it is not set,
+ return true if it succeeded."""
+ if not self.locked:
+ self.locked = 1
+ return 1
+ else:
+ return 0
- def lock(self, function, argument):
- """Lock a mutex, call the function with supplied argument
- when it is acquired. If the mutex is already locked, place
- function and argument in the queue."""
- if self.testandset():
- function(argument)
- else:
- self.queue.append((function, argument))
+ def lock(self, function, argument):
+ """Lock a mutex, call the function with supplied argument
+ when it is acquired. If the mutex is already locked, place
+ function and argument in the queue."""
+ if self.testandset():
+ function(argument)
+ else:
+ self.queue.append((function, argument))
- def unlock(self):
- """Unlock a mutex. If the queue is not empty, call the next
- function with its argument."""
- if self.queue:
- function, argument = self.queue[0]
- del self.queue[0]
- function(argument)
- else:
- self.locked = 0
+ def unlock(self):
+ """Unlock a mutex. If the queue is not empty, call the next
+ function with its argument."""
+ if self.queue:
+ function, argument = self.queue[0]
+ del self.queue[0]
+ function(argument)
+ else:
+ self.locked = 0