Python Programming by Example

Author:Agus Kurniawan [Kurniawan, Agus]
Language: eng
Format: epub
Publisher: PE Press
Published: 2015-11-19T23:00:00+00:00

11.3.1 Mutex Locks

The idea is a simple. When we access a resource, we call acquire(). If done, you call release() from Lock object.

For testing, we define a shared resource, such as a variable called value. This variable will be access by two threads. Only one thread can access this variable.

Ok, write these scripts.

import time import threading class MyThread(threading.Thread): def __init__(self, name, o_lock): threading.Thread.__init__(self) self.name = name self.running = False self.value_lock = o_lock def run(self): global value self.running = True while self.running: self.value_lock.acquire() value += 1 print('value:', str(value),' from ', self.name) self.value_lock.release() time.sleep(2) def stop(self): print('stopping ', self.name) self.running = False self.join(2) global value value = 0 value_lock = threading.Lock() my_thread1 = MyThread('Thread 1',value_lock) my_thread1.setDaemon(True) my_thread2 = MyThread('Thread 2',value_lock) my_thread2.setDaemon(True) my_thread1.start() my_thread2.start() # python 3 input("Press Enter to stop...") # python 2 #raw_input("Press Enter to stop...") my_thread1.stop() my_thread2.stop()

Download

Copyright Disclaimer:
This site does not store any files on its server. We only index and link to content provided by other sites. Please contact the content providers to delete copyright contents if any and email us, we'll remove relevant links or contents immediately.