Python Multi thread

一個簡單的MULTI THREAD


from threading import Thread

def add_100():
 tmp = 0
 for i in range(0,100):
  tmp += i
 print tmp

def add_2000():
 tmp = 0
 for i in range(0,2000):
  tmp += i
 print tmp

threads = []
for func in [add_100, add_2000]:
   threads.append(Thread(target=func))
   threads[-1].start()

for thread in threads:
  
   thread.join()




試一下LOCK 之 無LOCK


from threading import Lock, Thread
import random, time
lock = Lock()
g = 0

def add_1000():

 global g
 #lock.acquire()
 for i in range(0,5):
  time.sleep(random.randrange(2, 5))
  g += 1
  print str(g) + "\n"
   #lock.release()

def add_2000():
 global g
 #lock.acquire()
 for i in range(0,5):
  time.sleep(random.randrange(2, 5))
  g += 10
  print str(g) + "\n"
 #lock.release()

threads = []
for func in [add_1000, add_2000]:
 threads.append(Thread(target=func))
 threads[-1].start()

for thread in threads:
 thread.join()



結果



1



11



21



22



32



33



43



44



54



55







g 這個參數被兩個thread 同時更動。









試一下LOCK 之 有LOCK


from threading import Lock, Thread
import random, time
lock = Lock()
g = 0

def add_1000():

 global g
 lock.acquire()
 for i in range(0,5):
  time.sleep(random.randrange(2, 5))
  g += 1
  print str(g) + "\n"
        lock.release()

def add_2000():
 global g
 lock.acquire()
 for i in range(0,5):
  time.sleep(random.randrange(2, 5))
  g += 10
  print str(g) + "\n"
 lock.release()

threads = []
for func in [add_1000, add_2000]:
 threads.append(Thread(target=func))
 threads[-1].start()

for thread in threads:
 thread.join()






結果



1



2



3



4



5



15



25



35



45



55







試試看RLock






from threading import Lock, Thread, RLock
import random, time
lock = RLock()
g = 0

def add_1000():

 global g
 
 for i in range(0,5):
  lock.acquire()
  time.sleep(random.randrange(2, 5))
  g += 1
  print str(g) + "\n"
 


 lock.release()


 lock.release()


 lock.release()


 lock.release()


 lock.release()


def add_2000():
 global g
 lock.acquire()
 for i in range(0,5):
  time.sleep(random.randrange(2, 5))
  g += 10
  print str(g) + "\n"
 lock.release()

threads = []
for func in [add_1000, add_2000]:
 threads.append(Thread(target=func))
 threads[-1].start()

for thread in threads:
 thread.join()








我們把lock.acquire()放在for回圈中，如果lock=Lock()，第一個回圈就會停住了。

因為Lock()一定需要lock.acquire()配一個lock.release()。

如果把lock = RLock()。lock.acquire()與lock.release()就可以如上例，重覆多次acquire, 再一次全部一起release()。





EVENTS




from threading import Lock, Thread, Event
import random, time
lock = Lock()
e = Event()
g = 0

def add_1000(e):

 global g
 for i in range(0,5):
  g += 1
  print str(g) + "\n"
  e.wait()
  print "yes go"
  e.clear()

def add_2000(e):
 global g
 
 for i in range(0,5):
  g += 10
  print str(g) + "\n"
  e.set()
 
threads = []
for func in [add_1000, add_2000]:
 threads.append(Thread(target=func, args=(event,)))
 threads[-1].start()

for thread in threads:
 thread.join()




結果


1


11


21


yes go


31


32


42


yes go


52


53


yes go


54




Event可以讓兩個thread構通, 藉由wait與set，由event.wait()等待另一個thread對event下set。原本wait就會解除。


由上例，可以看出add_2000會不斷送出event.set()讓event.wait()往下走。


本來期待可以出現


1


11


yes go


12


22


yes go


23


33


yes go


34


44


yes go


45


55


可以發現"yes go"只出現三次，因為add_2000送的set是不斷的送出，而add_1000的wait還沒有跑到。





Condition



from threading import Lock, Thread, Event,Condition
import random, time
lock = Lock()
e = Event()
c = Condition()
g = 0

def add_1000(c):

 global g
 for i in range(0,5):
  c.acquire()
  g += 1
  c.wait()
  g += 1
  print "yes go"
  print str(g) + "\n"
  c.release()

def add_2000(c):
 global g
 
 for i in range(0,5):
  c.acquire()
  g += 10
  print str(g) + "\n"
  c.notify()
  c.release()
 
threads = []
for func in [add_1000, add_2000]:
 threads.append(Thread(target=func, args=(con,)))
 threads[-1].start()

for thread in threads:
 thread.join()






結果


11

21

yes go
22

32

43

53

yes go
54








結果差不多，其實condition就是EVENT + LOCK, 以這個角度來說，CONDITON提供的是多個THREAD等待，等到條件成立，就會去使用某些共用的資源。



而EVENT則比較像提供的是多個THREAD等待，等到條件成立，獨立去做某個自的事。



但我們能不能把EVENT寫的很像CONDITION，當然也可以。不就是EVENT+LOCK麼！





































留言











張貼留言






























這個網誌中的熱門文章









python 找圖自動點擊





















需要 import 這幾個 module      import cv2   import numpy as np   import pyautogui   import time     滑鼠點擊     def click_image(image,pos,  action, timestamp,offset=5):       img = cv2.imread(image)       height, width, channels = img.shape       pyautogui.moveTo(pos[0] + offset, pos[1] + ,offset, timestamp)      pyautogui.click(button=action)    圖片尋找   def imagesearch(image, precision=0.8):      im = pyautogui.screenshot()      img_rgb = np.array(im)      img_gray = cv2.cvtColor(img_rgb, cv2.COLOR_BGR2GRAY)      template = cv2.imread(image, 0)      template.shape[::-1]       res = cv2.matchTemplate(img_gray, template, cv2.TM_CCOEFF_NORMED)      min_val, max_val, min_loc, max_loc = cv2.minMaxLoc(res)      if max_val < precision:          return [-1,-1]      return max_loc  #返回圖片座標     使用方式   if __name__ == '__main__':      pp =imagesearch("./1.png") #尋找1.png的圖。(把圖跟程式放同一個目錄下)      click_image("./1.png", pp, "left", 1)  #要點右鍵的話，就把"left"改成 "








閱讀完整內容










Python pyserial 抓取系統內的 COM PORT





















讀取COM1的資料，再把讀到的資料寫入一個 the_com1.txt的檔案中。   import serial  def connectCom():   ser = serial.Serial("COM1", 19200)   print ser.port   while 1:    f = open( 'the_com1.txt','a')    sline = ser.readline()    time1=datetime.datetime.now().strftime('%Y-%m-%d %H:%M:%S')    out10=time1,"COM1",sline.strip()    f.writelines(str(out10))    f.writelines("\n")    f.close()  如果我們不知道到底有那一些COM PORT可以讀呢？可以藉由以下的片段來得知目前有哪一些COM PORT存在。    import serial  def serial_ports():     p = ['COM%s' % (i + 1) for i in range(256)]     rlt = []   for port in p:    try:     s = serial.Serial(port)     s.close()     rlt.append(port)    except (OSError, serial.SerialException):     pass   return rlt 








閱讀完整內容










VBA EXCEL 工作表變化 馬上執行 的作法  Worksheet_Change




















圖片







沒想到還會用到 Excel 中的 VBA，當初寫VBA就是一段窮極無聊的日子，用Excel寫星象表…  現在居然要幫一位老大哥寫這樣的程式…當真所有的事，當下是很難知道它發生的意義是什麼…   癈話不多說   先開啟EXCEL，存成副檔名為xlsm，這樣可以使用巨集功能。       然後看一上面，標籤列，有無開發人員選項。        如果沒有，從   檔案->選項->自定功能區->開發人員(打勾)         如果有，點擊 visual basic，就可以開始寫VBA             我們的目的是這樣的，如果 worksheet中有任何的更動，都會執行一段程式。     所以我們先點擊左邊的工作表1，然後右邊的程式編輯欄中上面的選擇列中，選worksheet。要記得這個設定是 對應到個別的worksheet ，所以如果有其它工作表，要個別寫對應的程式。如下          接下來選右邊的change          選完就會自動產生兩個程式名。 Worksheet_Change與 Worksheet_SelectionChange，如下。Worksheet_Change是指任何在worksheet 上的變動，就會執行這個程式。Worksheet_SelectionChange是指，選定EXCEL中的格有變化，如本來選A1改點擊了B1，這個動作就會觸發Worksheet_SelectionChange。     我們在兩個程式中寫一個MsgBox, 如下   各位可以試試效果如何。只要點擊左上方，excel的小圖，就會回到excel的worksheet中。         我們在 Worksheet_Change中增加三行程式，會在A1, A2, A3格中填入a, b, c。 各位是否有推論，這樣的寫法，會產生無窮迴圈？ 這個很重要！在寫 Worksheet_Change程式時，要很小心，如果是 工作表1自己的 Worksheet_Change要對工作表1自己做改變，就會進入無窮迴圈。   所以我們要能自由的開關觸發功能。用   Application.EnableEvents      我們加入  Application.EnableEvents ，再試試看。      如此這般。








閱讀完整內容