python 多线程与多进程（python 多线程串行和并行的实例）
时间：2022-01-26 01:12:29 类别：脚本大全 浏览量：2988
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
您可能感兴趣
- python抽奖转盘代码（详解python--模拟轮盘抽奖游戏）
- python str类型怎么转换（Python3中的bytes和str类型详解）
- 怎样使用python图像处理（Python Image模块基本图像处理操作小结）
- python中list怎么用（详解python中list的使用）
- python自学编程笔记（Python 编程速成推荐）
- python字符串之基本操作小练习（Python数据类型之String字符串实例详解）
- python字符处理的函数（Python字符串内置函数功能与用法总结）
- pythonmysql使用教程（Python异步操作MySQL示例使用aiomysql）
- python支持面向对象的程序设计（Python面向对象程序设计之类的定义与继承简单示例）
- python的几种数据结构（python中的数据结构比较）
- 利用python合并pdf（Python合并同一个文件夹下所有PDF文件的方法）
- python 链表操作（Python3实现的判断环形链表算法示例）
- 用python实现atm银行系统（Python实现的银行系统模拟程序完整案例）
- 如何去阿里云解析域名（利用Python+阿里云实现DDNS动态域名解析的方法）
- python处理水印（Yii 使用intervention/image拓展实现图像处理功能）
- python装饰器怎么设置（深入了解和应用Python 装饰器 @decorator）
- 逐渐消失的东北八大怪现象，进步的社会里我们遗失的是什么（逐渐消失的东北八大怪现象）
- 今日大雪，大雪养生这样做，一年都有好气色（大雪养生这样做）
- 粗盐是什么 粗盐的功效与作用（粗盐的功效与作用）
- 会 吃人 的客机 从天堂到地狱只需5分钟，图-104如何做到（会吃人的客机）
- 男人犯的错，为什么要女人来承担（为什么要女人来承担）
- 心理学 四个金蟾，哪个最招财 测你今生的运势有多棒（心理学四个金蟾）
热门推荐
排行榜
- 1
- 2
- 3
- 4
- 5
- 6
- 7
- 8
- 9