python 多線程串行和并行的實(shí)例
更新時間：2019年02月22日 09:50:05 作者：zhaoyangjian724
今天小編就為大家分享一篇python 多線程串行和并行的實(shí)例，具有很好的參考價值，希望對大家有所幫助。一起跟隨小編過來看看吧
如下所示：
#coding=utf-8
import threading
import time
import cx_Oracle
from pprint import pprint
import csv
table_name = "dbtest.csv"
f = open(table_name + ".csv", "w")
def exp01():
conn = cx_Oracle.connect('test/test@192.168.137.2/serv')
cursor = conn.cursor()
owner = "system"
writer = csv.writer(f, lineterminator="\n", quoting=csv.QUOTE_NONNUMERIC)
tname = threading.current_thread()
print tname
exportOracleSql = "select 'exp01' from dual"
print exportOracleSql
x = cursor.execute(exportOracleSql)
time.sleep(1000)
cursor.close()
conn.close()
def exp02():
conn = cx_Oracle.connect('test/test@192.168.137.2/serv')
cursor = conn.cursor()
owner = "system"
writer = csv.writer(f, lineterminator="\n", quoting=csv.QUOTE_NONNUMERIC)
tname = threading.current_thread()
print tname
exportOracleSql = "select 'exp02' from dual"
print exportOracleSql
x = cursor.execute(exportOracleSql)
time.sleep(1000)
cursor.close()
conn.close()
def exp03():
conn = cx_Oracle.connect('test/test@192.168.137.2/serv')
cursor = conn.cursor()
owner = "system"
writer = csv.writer(f, lineterminator="\n", quoting=csv.QUOTE_NONNUMERIC)
tname = threading.current_thread()
print tname
exportOracleSql = "select 'exp03' from dual"
print exportOracleSql
x = cursor.execute(exportOracleSql)
time.sleep(1000)
cursor.close()
conn.close()
def exp04():
conn = cx_Oracle.connect('test/test@192.168.137.2/serv')
cursor = conn.cursor()
owner = "system"
writer = csv.writer(f, lineterminator="\n", quoting=csv.QUOTE_NONNUMERIC)
tname = threading.current_thread()
print tname
exportOracleSql = "select 'exp04' from dual"
print exportOracleSql
x = cursor.execute(exportOracleSql)
time.sleep(1000)
cursor.close()
conn.close()
def exp05():
conn = cx_Oracle.connect('test/test@192.168.137.2/serv')
cursor = conn.cursor()
owner = "system"
writer = csv.writer(f, lineterminator="\n", quoting=csv.QUOTE_NONNUMERIC)
tname = threading.current_thread()
print tname
exportOracleSql = "select 'exp05' from dual"
print exportOracleSql
x = cursor.execute(exportOracleSql)
time.sleep(1000)
cursor.close()
conn.close()
def exp06():
conn = cx_Oracle.connect('test/test@192.168.137.2/serv')
cursor = conn.cursor()
owner = "system"
writer = csv.writer(f, lineterminator="\n", quoting=csv.QUOTE_NONNUMERIC)
tname = threading.current_thread()
print tname
exportOracleSql = "select 'exp06' from dual"
print exportOracleSql
x = cursor.execute(exportOracleSql)
time.sleep(1000)
cursor.close()
conn.close()
def exp07():
conn = cx_Oracle.connect('test/test@192.168.137.2/serv')
cursor = conn.cursor()
owner = "system"
writer = csv.writer(f, lineterminator="\n", quoting=csv.QUOTE_NONNUMERIC)
tname = threading.current_thread()
print tname
exportOracleSql = "select 'exp07' from dual"
print exportOracleSql
x = cursor.execute(exportOracleSql)
time.sleep(1000)
cursor.close()
conn.close()
def exp08():
conn = cx_Oracle.connect('test/test@192.168.137.2/serv')
cursor = conn.cursor()
owner = "system"
writer = csv.writer(f, lineterminator="\n", quoting=csv.QUOTE_NONNUMERIC)
tname = threading.current_thread()
print tname
exportOracleSql = "select 'exp08' from dual"
print exportOracleSql
x = cursor.execute(exportOracleSql)
time.sleep(1000)
cursor.close()
conn.close()
def exp09():
conn = cx_Oracle.connect('test/test@192.168.137.2/serv')
cursor = conn.cursor()
owner = "system"
writer = csv.writer(f, lineterminator="\n", quoting=csv.QUOTE_NONNUMERIC)
tname = threading.current_thread()
print tname
exportOracleSql = "select 'exp09' from dual"
print exportOracleSql
x = cursor.execute(exportOracleSql)
time.sleep(1000)
cursor.close()
conn.close()
def exp10():
conn = cx_Oracle.connect('test/test@192.168.137.2/serv')
cursor = conn.cursor()
owner = "system"
writer = csv.writer(f, lineterminator="\n", quoting=csv.QUOTE_NONNUMERIC)
tname = threading.current_thread()
print tname
exportOracleSql = "select 'exp10' from dual"
print exportOracleSql
x = cursor.execute(exportOracleSql)
time.sleep(1000)
cursor.close()
conn.close()
def exp11():
conn = cx_Oracle.connect('test/test@192.168.137.2/serv')
cursor = conn.cursor()
owner = "system"
writer = csv.writer(f, lineterminator="\n", quoting=csv.QUOTE_NONNUMERIC)
tname = threading.current_thread()
print tname
exportOracleSql = "select 'exp11' from dual"
print exportOracleSql
x = cursor.execute(exportOracleSql)
time.sleep(1000)
cursor.close()
conn.close()
def exp12():
conn = cx_Oracle.connect('test/test@192.168.137.2/serv')
cursor = conn.cursor()
owner = "system"
writer = csv.writer(f, lineterminator="\n", quoting=csv.QUOTE_NONNUMERIC)
tname = threading.current_thread()
print tname
exportOracleSql = "select 'exp12' from dual"
print exportOracleSql
x = cursor.execute(exportOracleSql)
time.sleep(1000)
cursor.close()
conn.close()
def exp13():
conn = cx_Oracle.connect('test/test@192.168.137.2/serv')
cursor = conn.cursor()
owner = "system"
writer = csv.writer(f, lineterminator="\n", quoting=csv.QUOTE_NONNUMERIC)
tname = threading.current_thread()
print tname
exportOracleSql = "select 'exp13' from dual"
print exportOracleSql
x = cursor.execute(exportOracleSql)
time.sleep(1000)
cursor.close()
conn.close()
def exp14():
conn = cx_Oracle.connect('test/test@192.168.137.2/serv')
cursor = conn.cursor()
owner = "system"
writer = csv.writer(f, lineterminator="\n", quoting=csv.QUOTE_NONNUMERIC)
tname = threading.current_thread()
print tname
exportOracleSql = "select 'exp14' from dual"
print exportOracleSql
x = cursor.execute(exportOracleSql)
time.sleep(1000)
cursor.close()
conn.close()
threads = []
t1 = threading.Thread(target=exp01,name='exp01')
threads.append(t1)
t2 = threading.Thread(target=exp02,name='exp02')
threads.append(t2)
t2 = threading.Thread(target=exp03,name='exp03')
threads.append(t2)
t2 = threading.Thread(target=exp04,name='exp04')
threads.append(t2)
t2 = threading.Thread(target=exp05,name='exp05')
threads.append(t2)
t2 = threading.Thread(target=exp06,name='exp06')
threads.append(t2)
t2 = threading.Thread(target=exp07,name='exp07')
threads.append(t2)
t2 = threading.Thread(target=exp08,name='exp08')
threads.append(t2)
t2 = threading.Thread(target=exp09,name='exp09')
threads.append(t2)
t2 = threading.Thread(target=exp10,name='exp10')
threads.append(t2)
t2 = threading.Thread(target=exp11,name='exp11')
threads.append(t2)
t2 = threading.Thread(target=exp12,name='exp12')
threads.append(t2)
t2 = threading.Thread(target=exp13,name='exp13')
threads.append(t2)
t2 = threading.Thread(target=exp14,name='exp14')
threads.append(t2)
if __name__ == '__main__':
for t in threads:
#t.setDaemon(True)
t.start()
#t.run()
#t.start()
# print '3333333'
print threading.current_thread()
# print t.is_alive()
# print '3333333'
t.join()
print "all over "
輸出:
C:\Python27\python.exe C:/Users/TLCB/PycharmProjects/untitled/mycompany/thread/p7.py
<_MainThread(MainThread, started 156528)>
<_MainThread(MainThread, started 156528)>
<_MainThread(MainThread, started 156528)>
<_MainThread(MainThread, started 156528)>
<_MainThread(MainThread, started 156528)>
<_MainThread(MainThread, started 156528)>
<_MainThread(MainThread, started 156528)>
<_MainThread(MainThread, started 156528)>
<_MainThread(MainThread, started 156528)>
<_MainThread(MainThread, started 156528)>
<_MainThread(MainThread, started 156528)>
<_MainThread(MainThread, started 156528)>
<_MainThread(MainThread, started 156528)>
<_MainThread(MainThread, started 156528)>
<Thread(exp01, started 155004)>
select 'exp01' from dual
<Thread(exp12, started 155744)>
select 'exp12' from dual<Thread(exp02, started 155000)>
select 'exp02' from dual
<Thread(exp08, started 155728)>
select 'exp08' from dual
<Thread(exp06, started 155752)>
select 'exp06' from dual
<Thread(exp03, started 154816)>
select 'exp03' from dual
<Thread(exp09, started 156544)>
select 'exp09' from dual
<Thread(exp11, started 155760)>
select 'exp11' from dual
<Thread(exp04, started 154112)>
select 'exp04' from dual
<Thread(exp10, started 155764)><Thread(exp05, started 154640)>
select 'exp10' from dualselect 'exp05' from dual
<Thread(exp07, started 155188)>
select 'exp07' from dual
<Thread(exp13, started 154600)>
select 'exp13' from dual
<Thread(exp14, started 155804)>
select 'exp14' from dual
SID SERIAL# USERNAME PREV_SQL_ID
1 9 1179 TEST 01tjnxmmurdw7
2 10 75 TEST g5ph474nsjvwv
3 12 907 TEST 87mdhpgj9k5tz
4 419 1303 TEST 4g8r4bkf8aq3n
5 420 655 TEST 1rx9mjdvp1udx
6 421 1955 TEST 928r7khrtn4jd
7 424 51 TEST d6sgjjwpm74qz
8 839 3 TEST a1hg7hrwgrdqk
9 840 43 TEST fqjuj4qp5hmf0
10 841 111 TEST 2jzx0889h3k5n
11 1252 145 TEST awtzfbx7dhn88
12 1253 7 TEST 55tzs9gdmcd4p
13 1254 9 TEST 4v01fvb5sj7k4
14 1255 265 TEST 39bcsfjr5y62b
此時是并發(fā)執(zhí)行
改變join的位置:
#coding=utf-8
import threading
import time
import cx_Oracle
from pprint import pprint
import csv
table_name = "dbtest.csv"
f = open(table_name + ".csv", "w")
def exp01():
conn = cx_Oracle.connect('test/test@192.168.137.2/serv')
cursor = conn.cursor()
owner = "system"
writer = csv.writer(f, lineterminator="\n", quoting=csv.QUOTE_NONNUMERIC)
tname = threading.current_thread()
print tname
exportOracleSql = "select 'exp01' from dual"
print exportOracleSql
x = cursor.execute(exportOracleSql)
time.sleep(1000)
cursor.close()
conn.close()
def exp02():
conn = cx_Oracle.connect('test/test@192.168.137.2/serv')
cursor = conn.cursor()
owner = "system"
writer = csv.writer(f, lineterminator="\n", quoting=csv.QUOTE_NONNUMERIC)
tname = threading.current_thread()
print tname
exportOracleSql = "select 'exp02' from dual"
print exportOracleSql
x = cursor.execute(exportOracleSql)
time.sleep(1000)
cursor.close()
conn.close()
def exp03():
conn = cx_Oracle.connect('test/test@192.168.137.2/serv')
cursor = conn.cursor()
owner = "system"
writer = csv.writer(f, lineterminator="\n", quoting=csv.QUOTE_NONNUMERIC)
tname = threading.current_thread()
print tname
exportOracleSql = "select 'exp03' from dual"
print exportOracleSql
x = cursor.execute(exportOracleSql)
time.sleep(1000)
cursor.close()
conn.close()
def exp04():
conn = cx_Oracle.connect('test/test@192.168.137.2/serv')
cursor = conn.cursor()
owner = "system"
writer = csv.writer(f, lineterminator="\n", quoting=csv.QUOTE_NONNUMERIC)
tname = threading.current_thread()
print tname
exportOracleSql = "select 'exp04' from dual"
print exportOracleSql
x = cursor.execute(exportOracleSql)
time.sleep(1000)
cursor.close()
conn.close()
def exp05():
conn = cx_Oracle.connect('test/test@192.168.137.2/serv')
cursor = conn.cursor()
owner = "system"
writer = csv.writer(f, lineterminator="\n", quoting=csv.QUOTE_NONNUMERIC)
tname = threading.current_thread()
print tname
exportOracleSql = "select 'exp05' from dual"
print exportOracleSql
x = cursor.execute(exportOracleSql)
time.sleep(1000)
cursor.close()
conn.close()
def exp06():
conn = cx_Oracle.connect('test/test@192.168.137.2/serv')
cursor = conn.cursor()
owner = "system"
writer = csv.writer(f, lineterminator="\n", quoting=csv.QUOTE_NONNUMERIC)
tname = threading.current_thread()
print tname
exportOracleSql = "select 'exp06' from dual"
print exportOracleSql
x = cursor.execute(exportOracleSql)
time.sleep(1000)
cursor.close()
conn.close()
def exp07():
conn = cx_Oracle.connect('test/test@192.168.137.2/serv')
cursor = conn.cursor()
owner = "system"
writer = csv.writer(f, lineterminator="\n", quoting=csv.QUOTE_NONNUMERIC)
tname = threading.current_thread()
print tname
exportOracleSql = "select 'exp07' from dual"
print exportOracleSql
x = cursor.execute(exportOracleSql)
time.sleep(1000)
cursor.close()
conn.close()
def exp08():
conn = cx_Oracle.connect('test/test@192.168.137.2/serv')
cursor = conn.cursor()
owner = "system"
writer = csv.writer(f, lineterminator="\n", quoting=csv.QUOTE_NONNUMERIC)
tname = threading.current_thread()
print tname
exportOracleSql = "select 'exp08' from dual"
print exportOracleSql
x = cursor.execute(exportOracleSql)
time.sleep(1000)
cursor.close()
conn.close()
def exp09():
conn = cx_Oracle.connect('test/test@192.168.137.2/serv')
cursor = conn.cursor()
owner = "system"
writer = csv.writer(f, lineterminator="\n", quoting=csv.QUOTE_NONNUMERIC)
tname = threading.current_thread()
print tname
exportOracleSql = "select 'exp09' from dual"
print exportOracleSql
x = cursor.execute(exportOracleSql)
time.sleep(1000)
cursor.close()
conn.close()
def exp10():
conn = cx_Oracle.connect('test/test@192.168.137.2/serv')
cursor = conn.cursor()
owner = "system"
writer = csv.writer(f, lineterminator="\n", quoting=csv.QUOTE_NONNUMERIC)
tname = threading.current_thread()
print tname
exportOracleSql = "select 'exp10' from dual"
print exportOracleSql
x = cursor.execute(exportOracleSql)
time.sleep(1000)
cursor.close()
conn.close()
def exp11():
conn = cx_Oracle.connect('test/test@192.168.137.2/serv')
cursor = conn.cursor()
owner = "system"
writer = csv.writer(f, lineterminator="\n", quoting=csv.QUOTE_NONNUMERIC)
tname = threading.current_thread()
print tname
exportOracleSql = "select 'exp11' from dual"
print exportOracleSql
x = cursor.execute(exportOracleSql)
time.sleep(1000)
cursor.close()
conn.close()
def exp12():
conn = cx_Oracle.connect('test/test@192.168.137.2/serv')
cursor = conn.cursor()
owner = "system"
writer = csv.writer(f, lineterminator="\n", quoting=csv.QUOTE_NONNUMERIC)
tname = threading.current_thread()
print tname
exportOracleSql = "select 'exp12' from dual"
print exportOracleSql
x = cursor.execute(exportOracleSql)
time.sleep(1000)
cursor.close()
conn.close()
def exp13():
conn = cx_Oracle.connect('test/test@192.168.137.2/serv')
cursor = conn.cursor()
owner = "system"
writer = csv.writer(f, lineterminator="\n", quoting=csv.QUOTE_NONNUMERIC)
tname = threading.current_thread()
print tname
exportOracleSql = "select 'exp13' from dual"
print exportOracleSql
x = cursor.execute(exportOracleSql)
time.sleep(1000)
cursor.close()
conn.close()
def exp14():
conn = cx_Oracle.connect('test/test@192.168.137.2/serv')
cursor = conn.cursor()
owner = "system"
writer = csv.writer(f, lineterminator="\n", quoting=csv.QUOTE_NONNUMERIC)
tname = threading.current_thread()
print tname
exportOracleSql = "select 'exp14' from dual"
print exportOracleSql
x = cursor.execute(exportOracleSql)
time.sleep(1000)
cursor.close()
conn.close()
threads = []
t1 = threading.Thread(target=exp01,name='exp01')
threads.append(t1)
t2 = threading.Thread(target=exp02,name='exp02')
threads.append(t2)
t2 = threading.Thread(target=exp03,name='exp03')
threads.append(t2)
t2 = threading.Thread(target=exp04,name='exp04')
threads.append(t2)
t2 = threading.Thread(target=exp05,name='exp05')
threads.append(t2)
t2 = threading.Thread(target=exp06,name='exp06')
threads.append(t2)
t2 = threading.Thread(target=exp07,name='exp07')
threads.append(t2)
t2 = threading.Thread(target=exp08,name='exp08')
threads.append(t2)
t2 = threading.Thread(target=exp09,name='exp09')
threads.append(t2)
t2 = threading.Thread(target=exp10,name='exp10')
threads.append(t2)
t2 = threading.Thread(target=exp11,name='exp11')
threads.append(t2)
t2 = threading.Thread(target=exp12,name='exp12')
threads.append(t2)
t2 = threading.Thread(target=exp13,name='exp13')
threads.append(t2)
t2 = threading.Thread(target=exp14,name='exp14')
threads.append(t2)
if __name__ == '__main__':
for t in threads:
#t.setDaemon(True)
t.start()
#t.run()
#t.start()
# print '3333333'
print threading.current_thread()
# print t.is_alive()
# print '3333333'
t.join()
print "all over "
C:\Python27\python.exe C:/Users/TLCB/PycharmProjects/untitled/mycompany/thread/p7.py
<_MainThread(MainThread, started 154776)>
<Thread(exp01, started 156240)>
select 'exp01' from dual
此時變成串行,數(shù)據(jù)庫連接也只有一個:
SID SERIAL# USERNAME PREV_SQL_ID
1 421 1957 TEST 928r7khrtn4jd
以上這篇python 多線程串行和并行的實(shí)例就是小編分享給大家的全部內(nèi)容了，希望能給大家一個參考，也希望大家多多支持腳本之家。
相關(guān)文章
這篇文章主要介紹了Python基于回溯法子集樹模板解決野人與傳教士問題,簡單說明了野人與傳教士問題,并結(jié)合實(shí)例形式分析了Python使用回溯法子集樹模板解決野人與傳教士問題的步驟與相關(guān)操作技巧,需要的朋友可以參考下2017-09-09
Numpy 數(shù)組操作之元素添加、刪除和修改的實(shí)現(xiàn)
本文主要介紹了Numpy 數(shù)組操作之元素添加、刪除和修改的實(shí)現(xiàn)，文中通過示例代碼介紹的非常詳細(xì)，對大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價值，需要的朋友們下面隨著小編來一起學(xué)習(xí)學(xué)習(xí)吧2023-03-03
平常我們想給某些圖片添加文字水印,方法有很多,也有很多的工具可以方便的進(jìn)行,今天主要是對PIL庫的應(yīng)用,結(jié)合Python語言批量對圖片添加水印,文章通過代碼示例給大家介紹的非常詳細(xì),感興趣的同學(xué)可以參考一下2023-11-11
淺述python中argsort()函數(shù)的實(shí)例用法
本篇文章主要介紹了淺述python中argsort()函數(shù)的實(shí)例用法，詳細(xì)的介紹了argsort()函數(shù)的用法，具有一定的參考價值，感興趣的小伙伴們可以參考一下。2017-03-03
python實(shí)現(xiàn)Dijkstra算法的最短路徑問題
這篇文章主要介紹了python實(shí)現(xiàn)Dijkstra算法的最短路徑問題，文中通過示例代碼介紹的非常詳細(xì)，對大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價值，需要的朋友們下面隨著小編來一起學(xué)習(xí)學(xué)習(xí)吧2019-06-06
Python中識別圖片/滑塊驗(yàn)證碼準(zhǔn)確率極高的ddddocr庫詳解
驗(yàn)證碼的種類有很多，它是常用的一種反爬手段，包括：圖片驗(yàn)證碼，滑塊驗(yàn)證碼，等一些常見的驗(yàn)證碼場景。這里推薦一個簡單實(shí)用的識別驗(yàn)證碼的庫?ddddocr?(帶帶弟弟ocr)庫，希望大家喜歡2023-02-02
Python 類與元類的深度挖掘 II【經(jīng)驗(yàn)】
元類在 Python 中屬于比較深層的黑魔法，在一般的日常應(yīng)用中可能并不常用，但理解其背后的原理對于理解 Python 面向?qū)ο缶幊桃约耙磺薪詾閷ο蟮睦砟詈苡袔椭?；如果你需要對類進(jìn)行深度改造，至少要知道從何入手。2016-05-05
Python運(yùn)行的慢是歷來被詬病的，本文就來介紹一下python運(yùn)行加速的幾種方式，具有一定的參考價值，感興趣的小伙伴們可以參考一下2021-07-07
這篇文章主要介紹了Python isinstance函數(shù)介紹,本文用實(shí)例講解了判斷變量是否是某個指定類型,需要的朋友可以參考下2015-04-04
Python中pip安裝非PyPI官網(wǎng)第三方庫的方法
這篇文章主要介紹了Python中pip安裝非PyPI官網(wǎng)第三方庫的方法,pip最新的版本(1.5以上的版本), 出于安全的考 慮,pip不允許安裝非PyPI的URL,本文就給出兩種解決方法,需要的朋友可以參考下2015-06-06