标签:for 数字 threading rom 进程 pen turn 优先级队列 cti
threading模块提供的一些方法:
threading.currentThread() 返回当前的线程变量
threading.enumerate() 返回一个包含正在运行的线程的list,正在运行指线程启动后,结束前,不包括启动前和终止后的线程
threading.activeCount() 返回正在运行的线程数量,与len(threading.enumerate()有相同的结果)
实例:
import threading import time from threading import Thread,current_thread def f1(n): time.sleep(1) print(‘子线程名称‘, current_thread().getName()) #Thread-1 print(‘%s号线程任务‘%n) if __name__ == ‘__main__‘: t1 = Thread(target=f1,args=(1,)) t1.start() print(‘主线程名称‘,current_thread().getName()) #MainThread print(‘主线程ID‘,current_thread().ident) print(current_thread()) print(threading.enumerate()) #[<_MainThread(MainThread, started 6708)>, <Thread(Thread-1, started 7848)>] print(threading.active_count()) # print(‘主线程‘)
线程队列:
共有三种基本用法:Queue,LifoQueue,PriorityQueue 一:先进先出队列 q = queue.Queue(3) #先进先出 fifo first in first out q.put(1) q.put(2) # print(‘当前队列内容长度‘,q.qsize()) q.put(3) print(‘查看队列是否满了‘,q.full()) try: q.put_nowait(4) # 报错queue.Full except Exception: print(‘队列满了‘) print(q.get()) print(q.get()) print(‘查看队列是否为空‘,q.empty()) print(q.get()) print(‘查看队列是否为空‘,q.empty()) try: q.get_nowait() # queue.Empty except Exception: print(‘队列空了‘) 二 先进后出队列,或者后进先出,类似于栈 q = queue.LifoQueue(3) q.put(1) q.put(2) q.put(3) print(q.get()) print(q.get()) print(q.get()) 三,优先级队列 q = queue.PriorityQueue(5) # q.put((5,‘glex‘)) q.put((5,(2,3))) #如果说值里面的元素是数字类型,那么当两个值的优先级相同时,比较的是两个值的大小,小的优先被取出来 #如果元素是字符串,那么依次比较每个字母的ascii表中的位置,小的优先被取出来 q.put((5,(2,2,3))) q.put((2,‘zasdf‘)) q.put((-1,‘yadsf‘)) q.put((2,{‘k‘:666})) #如果优先级数字相同,如果数据类型不同会报错 q.put((2,(‘a‘,‘b‘))) q.put((1,(1,2))) q.put((3,(1,2))) q.put((-10,(1,2))) print(q.get()) print(q.get()) print(q.get())
线程池:
1.使用multiprocessing模块创建 from threading import Thread thread_pool = ThreadPoolManger(4) 使用concurrent.futures模块创建 将进程池和线程池放到一起,统一使用方式,使用threadPollExecutor和ProcessPollExecutor的方式一样,而且只要通过这个concurrent.futures导入就可以直接用他们两个了 p = ThreadPoolExecutor(4) # 默认个数是 cpu的个数*5 p = ProcessPoolExecutor(4) # 默认个数是cpu的核数 import time from threading import current_thread from concurrent.futures import ThreadPoolExecutor,ProcessPoolExecutor def f1(n,s): time.sleep(1) # print(‘%s号子线程‘%current_thread().ident) # print(n,s) return if __name__ == ‘__main__‘: tp = ThreadPoolExecutor(4) # tp = ProcessPoolExecutor(4) # tp.map(f1,range(10)) #异步提交任务,参数同样是任务名称,可迭代对象 res_list = [] for i in range(10): res = tp.submit(f1,i,‘baobao‘) #submit是给线程池异步提交任务, print(res) # res.result() res_list.append(res) # for r in res_list: # print(r.result()) tp.shutdown() #主线程等待所有提交给线程池的任务,全部执行完毕 close + join for r in res_list: print(r.result()) print(‘主线程结束‘)
标签:for 数字 threading rom 进程 pen turn 优先级队列 cti
原文地址:https://www.cnblogs.com/topass123/p/12817325.html