python 多執行緒實現 threading

# encoding: utf-8

#!/usr/bin/python
import threading
import time
import queue
exit =
0class
testthread
(threading.thread)
:def
__init__
(self,
id, name, counter)
:        threading.thread.__init__(self)
self.threadid =
id        self.name = name
self.counter = counter
# def run(self):
#     print("開始" + self.name)
#     testtime(self.name, self.counter, 5)
#     print("結束" + self.name)
# def testtime(num, delay,counter):
#     while counter:
#         if exit:
#             thread.exit()
#         time.sleep(delay)
#         print("%s:%s"% (num,time.ctime(time.time())))
#         counter -= 1
## thread1 = testthread(1, "執行緒1", 1)
# thread2 = testthread(2, "執行緒2", 2)
## thread1.start()
# thread2.start()
## print("結束多執行緒")
#     def run(self):
#         print("開始" + self.name)
#         threadlock.acquire()
#         print_time(self.name,self.counter,3)
#         threadlock.release()
## def print_time(threadname, delay, counter):
#     while counter:
#         time.sleep(delay)
#         print ("%s: %s" % (threadname, time.ctime(time.time())))
#         counter -= 1
## threadlock = threading.lock()
# threads = 
## thread1 = testthread(1, "執行緒1", 1)
# thread2 = testthread(2, "執行緒2", 2)
# thread1.start()
# thread2.start()
## for over in threads:
#    over.join()
# print("結束多執行緒")

使用thread物件的lock和rlock可以實現簡單的執行緒同步，這兩個物件都有acquire方法和release方法，對於那些需要每次只允許乙個執行緒操作的資料，可以將其操作放到acquire和release方法之間。

python多執行緒實現

資料夾命名不能用官方已有的模組名比如threading.py test.py等等都會報錯 from multiprocessing import process import os 子程序要執行的 def run proc name print run child process s s name,...

python多執行緒實現

coding utf 8 import threading 匯入執行緒模組 from time import ctime,sleep 建立執行緒事件 defeat print 我在吃東西 s ctime 執行緒組 threads 建立執行緒數量 for x in range 10 t1 thread...

python多執行緒執行緒池實現

在python中多執行緒可以使用threading來實現，但實際使用時考慮效能等，大多會使用到執行緒池，下面就是基於python2和python3來說明下執行緒池的使用。import time def testthread fl time.sleep 1 print print fl return ...