javaDSL簡略完成示例分享。本站提示廣大學習愛好者：（javaDSL簡略完成示例分享）文章只能為提供參考，不一定能成為您想要的結果。以下是javaDSL簡略完成示例分享正文
1. 多線程的感化
簡而言之，多線程是並行處置互相自力的子義務，從而年夜幅度進步全部義務的效力。
2. Python中的多線程相干模塊和辦法
Python中供給幾個用於多線程編程的模塊，包含thread，threading和Queue等
thread模塊供給了根本的線程和鎖的支撐，除發生線程外，也供給根本的同步數據構造鎖對象，個中包含：
start_new_thread(function, args kwargs=None) 發生一個新的線程來運轉給定函數
allocate_lock() 分派一個LockType類型的鎖對象
exit() 讓線程加入
acquire(wait=None) 測驗考試獲得鎖對象
locked() 假如獲得了鎖對象前往TRUE，不然前往FALSE
release() 釋放鎖
threading供給了更高等別，功效更強的線程治理功效
Thread類 表現一個線程的履行的對象
Lock 鎖原語對象
RLock 可重入鎖對象，使單線程可以再次取得曾經獲得鎖
queue模塊許可用戶創立一個可以用於多個線程之間同享數據的隊列數據構造
可用於過程間的通信，讓各個線程之間同享數據
模塊函數queue(size) 創立一個年夜小為size的Queue對象
queue對象函數 qsize() 前往隊列年夜小
empty() 隊列為空前往True，不然前往False
put(item, block=0) 把ITEM放到隊列中，block不為0，函數會一向壅塞到隊列中
get(block=0) 從隊列中取一個對象，若果給block，函數會一向壅塞到隊列中有對象為止
3.示例
今朝Python的lib中對多線程編程供給兩種啟動辦法，一種是比擬根本的thread模塊中start_new_thread辦法，在線程中運轉一個函數， 另外一種是應用集成threading模塊的線程對象Thread類。
今朝所用到的，是舊版本中挪用thread模塊中的start_new_thread()函數來發生新的線程
比擬而言，thread.start_new_thread(function,(args[,kwargs]))完成機制其實與C更加相似，個中function參數是將要挪用的線程函數；(args[,kwargs])是將傳遞給待創立線程函數的參數構成的元組類型，個中kwargs是可選的參數。新創立的線程停止普通依附線程函數的履行停止主動加入，或許在線程函數中挪用thread.exit()拋出SystemExit exception，到達線程加入的目標。
print "=======================thread.start_new_thread啟動線程============="
import thread
#Python的線程sleep辦法其實不是在thread模塊中，反而是在time模塊下
import time
def inthread(no,interval):
count=0
while count<10:
print "Thread-%d,休眠距離：%d,current Time:%s"%(no,interval,time.ctime())
#使以後線程休眠指准時間，interval為浮點型的秒數，分歧於Java中的整形毫秒數
time.sleep(interval)
#Python不像年夜多半高等說話一樣支撐++操作符，只能用+=完成
count+=1
else:
print "Thread-%d is over"%no
#可以期待線程被PVM收受接管，或自動挪用exit或exit_thread辦法停止線程
thread.exit_thread()
#應用start_new_thread函數可以簡略的啟動一個線程,第一個參數指定線程中履行的函數，第二個參數為元組型的傳遞給指定函數的參數值
thread.start_new_thread(inthread,(1,2))
#線程履行時必需添加這一行，而且sleep的時光必需足夠使線程停止，如本例
#假如休眠時光改成20，將能夠會拋出異常
time.sleep(30)
'''
應用這類辦法啟動線程時，有能夠湧現異常
Unhandled exception in thread started by Error in sys.excepthook: Original exception was:
處理：啟動線程以後，須確保主線程期待一切子線程前往成果後再加入，假如主線程比子線程早停止，不管其子線程能否是後台線程，都將會中止，拋出這個異常
若沒有呼應壅塞期待，為防止主線程提早加入，必需挪用time.sleep使主線程休眠足夠長的時光，別的也能夠采取加鎖機制來防止相似情形，經由過程在啟動線程的時刻，給每一個線程都加了一把鎖，直到線程運轉引見，再釋放這個鎖。同時在Python的main線程頂用一個while輪回來一直的斷定每一個線程鎖已釋放。
import thread;
from time import sleep,ctime;
from random import choice
#The first param means the thread number
#The second param means how long it sleep
#The third param means the Lock
def loop(nloop,sec,lock):
print "Thread ",nloop," start and will sleep ",sec;
sleep(sec);
print "Thread ",nloop," end ",sec;
lock.release();
def main():
seconds=[4,2];
locks=[];
for i in range(len(seconds)) :
lock=thread.allocate_lock();
lock.acquire();
locks.append(lock);
print "main Thread begins:",ctime();
for i,lock in enumerate(locks):
thread.start_new_thread(loop,(i,choice(seconds),lock));
for lock in locks :
while lock.locked() :
pass;
print "main Thread ends:",ctime();
if __name__=="__main__" :
main();
許多引見說在新python版本中推舉應用Threading模塊，今朝暫沒有運用到。。。
