Python学习——Python线程

 1 #方法一：将要执行的方法作为参数传给Thread的构造方法
 2 import threading
 3 import time
 4 
 5 def show(arg):
 6     time.sleep(2)
 7     print(‘thread‘ + str(arg))
 8 
 9 for i in range(10):
10     t = threading.Thread(target=show,args=(i,))
11     time.sleep(2)
12     t.start()
13 
14 #方法2：从Thread继承，并重写run()
15 class MyThread(threading.Thread):
16     def __init__(self,num):
17         threading.Thread.__init__(self)
18         self.num = num
19 
20     def run(self)):#定义每个线程要运行的函数
21         print("running on number:%s" %self.num)
22         time.sleep(3)
23 
24 
25 if __name__ ==  ‘__main__‘:
26     t1 = MyThread(1)
27     t2 = MyThread(2)
28     t1.start()
29     time.sleep(3)
30     t2.start()

 1 import threading
 2 from time import ctime,sleep
 3 
 4 def music(func):
 5     for i in range(2):
 6         print("I was listening to %s. %s" %(func,ctime()))
 7         sleep(1)
 8 def move(func):
 9     for i in range(2):
10         print("I was at the %s! %s" %(func,ctime()))
11         sleep(5)
12 
13 threads = []
14 t1 = threading.Thread(target=music,args=(‘童话镇‘,))
15 threads.append(t1)
16 t2 = threading.Thread(target=move,args=(‘变形金刚‘,))
17 threads.append(t2)
18 
19 if __name__ == ‘__main__‘:
20     for t in threads:
21         t.setDaemon(True)
22         t.start()
23 
24     print("all over %s" %ctime())

1 if __name__ == ‘__main__‘:
2     for t in threads:
3         t.setDaemon(True)
4         t.start()
5     
6     t.join()
7 
8     print "all over %s" %ctime()

1 ############运行结果###################
2 I was listening to 童话镇. Thu Jun 22 23:34:22 2017
3 I was at the 变形金刚! Thu Jun 22 23:34:22 2017
4 I was listening to 童话镇. Thu Jun 22 23:34:23 2017
5 I was at the 变形金刚! Thu Jun 22 23:34:27 2017
6 all over Thu Jun 22 23:34:32 2017

 1 import threading
 2 import time
 3 
 4 num = 0
 5 
 6 def show(arg):
 7     global num
 8     time.sleep(1)
 9     num +=1
10     print(num)
11 
12 for i in range(10):
13     t = threading.Thread(target=show, args=(i,))
14     t.start()
15 
16 print(‘main thread stop‘)

 1 import threading
 2 import time
 3 
 4 num = 0
 5 lock = threading.RLock()
 6 
 7 # 调用acquire([timeout])时，线程将一直阻塞，
 8 # 直到获得锁定或者直到timeout秒后（timeout参数可选）。
 9 # 返回是否获得锁。
10 def show(arg):
11     lock.acquire()
12     global num
13     time.sleep(1)
14     num +=1
15     print(num)
16     lock.release()
17 
18 for i in range(10):
19     t = threading.Thread(target=show, args=(i,))
20     t.start()
21 
22 print(‘main thread stop‘)

 1 import threading, time
 2 
 3 def run(n):
 4     semaphore.acquire()
 5     time.sleep(3)
 6     print("run the thread: %s" % n)
 7     semaphore.release()
 8 
 9 if __name__ == ‘__main__‘:
10     num = 0
11     semaphore = threading.BoundedSemaphore(5)  # 最多允许5个线程同时运行
12     for i in range(20):
13         t = threading.Thread(target=run, args=(i,))
14         t.start()

 1 import threading
 2 
 3 def do(event):
 4     print(‘start‘)
 5     event.wait()
 6     print(‘end‘)
 7 
 8 event_obj = threading.Event()
 9 
10 for i in range(10):
11     t = threading.Thread(target=do, args=(event_obj,))
12     t.start()
13 
14 event_obj.clear() #继续阻塞
15 
16 inp = input(‘input:‘)
17 if inp == ‘true‘:
18     event_obj.set()  # 唤醒