python 多线程与多进程
python 多线程串行和并行的实例如下所示：
|
|
#coding=utf-8import threadingimport timeimport cx_Oraclefrom pprint import pprintimport csvtable_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_ID1 9 1179 TEST 01tjnxmmurdw72 10 75 TEST g5ph474nsjvwv3 12 907 TEST 87mdhpgj9k5tz4 419 1303 TEST 4g8r4bkf8aq3n5 420 655 TEST 1rx9mjdvp1udx6 421 1955 TEST 928r7khrtn4jd7 424 51 TEST d6sgjjwpm74qz8 839 3 TEST a1hg7hrwgrdqk9 840 43 TEST fqjuj4qp5hmf010 841 111 TEST 2jzx0889h3k5n11 1252 145 TEST awtzfbx7dhn8812 1253 7 TEST 55tzs9gdmcd4p13 1254 9 TEST 4v01fvb5sj7k414 1255 265 TEST 39bcsfjr5y62b 此时是并发执行 改变join的位置:#coding=utf-8import threadingimport timeimport cx_Oraclefrom pprint import pprintimport csvtable_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 此时变成串行,数据库连接也只有一个: SID SERIAL# USERNAME PREV_SQL_ID1 421 1957 TEST 928r7khrtn4jd |
以上这篇python 多线程串行和并行的实例就是小编分享给大家的全部内容了，希望能给大家一个参考，也希望大家多多支持开心学习网。
原文链接：https://blog.csdn.net/zhaoyangjian724/article/details/77910808