ubuntu 12 Aug

C-002 · C-002 · commit f37281ca76ad · 2019-08-12T07:54:00.000-07:00
diff --git a/System/Processes/thread_classes.py b/System/Processes/thread_classes.py
@@ -0,0 +1,28 @@
+import threading
+
+class Mythread(threading.Thread):
+    def __init__(self, myId, count, mutex):
+        self.myId = myId
+        self.count = count
+        self.mutex = mutex
+        threading.Thread.__init__(self)
+
+    def run(self):
+        for i in range(self.count):
+            with self.mutex:
+                print('[%s] => %s' % (self.myId, i))
+
+stdoutmutex = threading.Lock()
+
+threads = []
+
+for i in range(3):
+    thread = Mythread(i, 10, stdoutmutex)
+    thread.start()
+    threads.append(thread)
+
+for thread in threads:
+    thread.join()
+
+print('Main thread exting.')
+
diff --git a/System/Processes/thread_count_wait1.py b/System/Processes/thread_count_wait1.py
@@ -0,0 +1,33 @@
+import _thread as thread
+
+stdoutmutex = thread.allocate_lock()
+exitmutexes = [thread.allocate_lock() for i in range(3)]
+
+def counter(myId, count):
+    for i in range(count):
+        stdoutmutex.acquire()
+        print('[%s] => %s' % (myId, i))
+        stdoutmutex.release()
+    
+    exitmutexes[myId].acquire()
+    for mutex in exitmutexes:
+        print(mutex.locked())
+
+for i in range(3):
+    thread.start_new_thread(counter, (i, 10))
+
+for mutex in exitmutexes:
+    while not mutex.locked(): pass
+
+for mutex in exitmutexes:
+    print(mutex.locked())
+
+for mutex in exitmutexes:
+    mutex.release()
+
+for mutex in exitmutexes:
+    print(mutex.locked())
+
+
+print('Main thread exiting!')
+
diff --git a/System/Processes/thread_count_wait2.py b/System/Processes/thread_count_wait2.py
@@ -0,0 +1,20 @@
+import _thread as thread
+
+stdoutmutex = thread.allocate_lock()
+
+exitmutexes = [False] * 3
+
+def counter(myId, count):
+    for i in range(count):
+        stdoutmutex.acquire()
+        print('[%s] => %s' % (myId, i))
+        stdoutmutex.release()
+
+    exitmutexes[myId] = True
+
+for i in range(3):
+    thread.start_new_thread(counter, (i, 10))
+
+while False in exitmutexes: pass
+
+print('Main thread exiting!')
diff --git a/System/Processes/thread_count_wait3.py b/System/Processes/thread_count_wait3.py
@@ -0,0 +1,20 @@
+import _thread as thread
+import time
+
+stdoutmutex = thread.allocate_lock()
+numthread = 5
+exitmutexes = [thread.allocate_lock() for i in range(numthread)]
+
+def counter(myId, count, mutex):
+    for i in range(count):
+        time.sleep(1 / (myId + 1))
+        with mutex:
+            print('[%s] => %s' % (myId, i))
+    exitmutexes[myId].acquire()
+
+for i in range(numthread):
+    thread.start_new_thread(counter, (i, 5, stdoutmutex))
+
+while not all(mutex.locked() for mutex in exitmutexes): pass
+
+print('Main thread exiting!')
