意識(shí)到了程序在執(zhí)行時(shí)間上的提升
我們寫(xiě)了一個(gè)多線(xiàn)程程序來(lái)減少cpu的等待時(shí)間，當(dāng)我們?cè)诘却粋€(gè)線(xiàn)程內(nèi)的網(wǎng)絡(luò)請(qǐng)求返回時(shí)，這時(shí)cpu可以切換到其他線(xiàn)程去進(jìn)行其他線(xiàn)程內(nèi)的網(wǎng)絡(luò)請(qǐng)求。
我們期望一個(gè)線(xiàn)程處理一個(gè)url，所以實(shí)例化線(xiàn)程類(lèi)的時(shí)候我們傳了一個(gè)url。
線(xiàn)程運(yùn)行意味著執(zhí)行類(lèi)里的run()方法。
無(wú)論如何我們想每個(gè)線(xiàn)程必須執(zhí)行run()。
為每個(gè)url創(chuàng)建一個(gè)線(xiàn)程并且調(diào)用start()方法，這告訴了cpu可以執(zhí)行線(xiàn)程中的run()方法了。
我們希望所有的線(xiàn)程執(zhí)行完畢的時(shí)候再計(jì)算花費(fèi)的時(shí)間，所以調(diào)用了join()方法。
join()可以通知主線(xiàn)程等待這個(gè)線(xiàn)程結(jié)束后，才可以執(zhí)行下一條指令。
每個(gè)線(xiàn)程我們都調(diào)用了join()方法，所以我們是在所有線(xiàn)程執(zhí)行完畢后計(jì)算的運(yùn)行時(shí)間。

關(guān)于線(xiàn)程：

cpu可能不會(huì)在調(diào)用start()后馬上執(zhí)行run()方法。
你不能確定run()在不同線(xiàn)程建間的執(zhí)行順序。
對(duì)于單獨(dú)的一個(gè)線(xiàn)程，可以保證run()方法里的語(yǔ)句是按照順序執(zhí)行的。
這就是因?yàn)榫€(xiàn)程內(nèi)的url會(huì)首先被請(qǐng)求，然后打印出返回的結(jié)果。

實(shí)例2

我們將會(huì)用一個(gè)程序演示一下多線(xiàn)程間的資源競(jìng)爭(zhēng)，并修復(fù)這個(gè)問(wèn)題。

from threading import Thread
 
#define a global variable
some_var=0
 
classIncrementThread(Thread):
  defrun(self):
    #we want to read a global variable
    #and then increment it
    globalsome_var
    read_value=some_var
    print”some_var in %s is %d”%(self.name, read_value)
    some_var=read_value+1
    print”some_var in %s after increment is %d”%(self.name, some_var)
 
defuse_increment_thread():
  threads=[]
  foriinrange(50):
    t=IncrementThread()
    threads.append(t)
    t.start()
  fortinthreads:
    t.join()
  print”After 50 modifications, some_var should have become 50″
  print”After 50 modifications, some_var is %d”%(some_var,)
 
use_increment_thread()

多次運(yùn)行這個(gè)程序，你會(huì)看到多種不同的結(jié)果。
解釋?zhuān)?/strong>
有一個(gè)全局變量，所有的線(xiàn)程都想修改它。
所有的線(xiàn)程應(yīng)該在這個(gè)全局變量上加 1 。
有50個(gè)線(xiàn)程，最后這個(gè)數(shù)值應(yīng)該變成50，但是它卻沒(méi)有。
為什么沒(méi)有達(dá)到50？
在some_var是15的時(shí)候，線(xiàn)程t1讀取了some_var，這個(gè)時(shí)刻cpu將控制權(quán)給了另一個(gè)線(xiàn)程t2。
t2線(xiàn)程讀到的some_var也是15
t1和t2都把some_var加到16
當(dāng)時(shí)我們期望的是t1 t2兩個(gè)線(xiàn)程使some_var + 2變成17
在這里就有了資源競(jìng)爭(zhēng)。
相同的情況也可能發(fā)生在其它的線(xiàn)程間，所以出現(xiàn)了最后的結(jié)果小于50的情況。
解決資源競(jìng)爭(zhēng)

from threading import Lock, Thread
lock=Lock()
some_var=0
 
classIncrementThread(Thread):
  defrun(self):
    #we want to read a global variable
    #and then increment it
    globalsome_var
    lock.acquire()
    read_value=some_var
    print”some_var in %s is %d”%(self.name, read_value)
    some_var=read_value+1
    print”some_var in %s after increment is %d”%(self.name, some_var)
    lock.release()
 
defuse_increment_thread():
  threads=[]
  foriinrange(50):
    t=IncrementThread()
    threads.append(t)
    t.start()
  fortinthreads:
    t.join()
  print”After 50 modifications, some_var should have become 50″
  print”After 50 modifications, some_var is %d”%(some_var,)
 
use_increment_thread()

from threading import Thread
import time
 
classCreateListThread(Thread):
  defrun(self):
    self.entries=[]
    foriinrange(10):
      time.sleep(1)
      self.entries.append(i)
    printself.entries
 
defuse_create_list_thread():
  foriinrange(3):
    t=CreateListThread()
    t.start()
 
use_create_list_thread()

from threading import Thread, Lock
import time
 
lock=Lock()
 
classCreateListThread(Thread):
  defrun(self):
    self.entries=[]
    foriinrange(10):
      time.sleep(1)
      self.entries.append(i)
    lock.acquire()
    printself.entries
    lock.release()
 
defuse_create_list_thread():
  foriinrange(3):
    t=CreateListThread()
    t.start()
 
use_create_list_thread()