add lock, multithreading, threadlocal samples

michaelliao · michaelliao · commit 3d77f04a6ce1 · 2015-04-01T16:30:27.000+08:00
diff --git a/py3/multitask/do_lock.py b/py3/multitask/do_lock.py
@@ -0,0 +1,33 @@
+#!/usr/bin/env python3
+# -*- coding: utf-8 -*-
+
+import time, threading
+
+# &#20551;&#23450;&#36825;&#26159;&#20320;&#30340;&#38134;&#34892;&#23384;&#27454;:
+balance = 0
+lock = threading.Lock()
+
+def change_it(n):
+    # &#20808;&#23384;&#21518;&#21462;&#65292;&#32467;&#26524;&#24212;&#35813;&#20026;0:
+    global balance
+    balance = balance + n
+    balance = balance - n
+
+def run_thread(n):
+    for i in range(100000):
+        # &#20808;&#35201;&#33719;&#21462;&#38145;:
+        lock.acquire()
+        try:
+            # &#25918;&#24515;&#22320;&#25913;&#21543;:
+            change_it(n)
+        finally:
+            # &#25913;&#23436;&#20102;&#19968;&#23450;&#35201;&#37322;&#25918;&#38145;:
+            lock.release()
+
+t1 = threading.Thread(target=run_thread, args=(5,))
+t2 = threading.Thread(target=run_thread, args=(8,))
+t1.start()
+t2.start()
+t1.join()
+t2.join()
+print(balance)
diff --git a/py3/multitask/multi_threading.py b/py3/multitask/multi_threading.py
@@ -0,0 +1,20 @@
+#!/usr/bin/env python3
+# -*- coding: utf-8 -*-
+
+import time, threading
+
+# &#26032;&#32447;&#31243;&#25191;&#34892;&#30340;&#20195;&#30721;:
+def loop():
+    print('thread %s is running...' % threading.current_thread().name)
+    n = 0
+    while n < 5:
+        n = n + 1
+        print('thread %s >>> %s' % (threading.current_thread().name, n))
+        time.sleep(1)
+    print('thread %s ended.' % threading.current_thread().name)
+
+print('thread %s is running...' % threading.current_thread().name)
+t = threading.Thread(target=loop, name='LoopThread')
+t.start()
+t.join()
+print('thread %s ended.' % threading.current_thread().name)
diff --git a/py3/multitask/use_threadlocal.py b/py3/multitask/use_threadlocal.py
@@ -0,0 +1,24 @@
+#!/usr/bin/env python3
+# -*- coding: utf-8 -*-
+
+import threading
+
+# &#21019;&#24314;&#20840;&#23616;ThreadLocal&#23545;&#35937;:
+local_school = threading.local()
+
+def process_student():
+    # &#33719;&#21462;&#24403;&#21069;&#32447;&#31243;&#20851;&#32852;&#30340;student:
+    std = local_school.student
+    print('Hello, %s (in %s)' % (std, threading.current_thread().name))
+
+def process_thread(name):
+    # &#32465;&#23450;ThreadLocal&#30340;student:
+    local_school.student = name
+    process_student()
+
+t1 = threading.Thread(target= process_thread, args=('Alice',), name='Thread-A')
+t2 = threading.Thread(target= process_thread, args=('Bob',), name='Thread-B')
+t1.start()
+t2.start()
+t1.join()
+t2.join()
