day34 线程池协程

今日内容:

1. 线程的其他方法

2.线程队列(重点)

3.线程池(重点)

4.协程

1.线程的其他方法

语法:

Threading.current_thread() # 当前正在运行的线程对象的一个列表

GetName() # 获取线程名

Ident() 获取线程的ID

Threading.active_count() # 当前正在运行的线程数量

import threading
import time
from threading import Thread,current_thread

def f1():
    time.sleep(1)
    print('子进程的名称',current_thread().getName())  # Thread-1
    print(f'{i}号线程任务')

if __name__=='__main__':
    t1=Thread(target=f1,args=(2,))
    t1.start()
    print('主线程名称',current_thread().getName())  # MainThread
    print('主线程ID',current_thread().ident)  # 查看主线程ID
    print(current_thread())
    print(threading.enumerate()) #[<_MainThread(MainThread, started 6708)>,
 <Thread(Thread-1, started 7848)>]
    
    print(threading.active_count()) #主线程和子线程的和
    print('主线程结束')

2.线程队列(重点)

Put的数据是一个元组,元组的第一个参数是优先级数字,数字越小优先级越高,越先被get到被取出来,第二个参数是put进去的值,如果说优先级相同,那么值别忘了应该是相同的数据类型,字典不行

线程队列我们这里介绍3种:

import queue

1).先进先出队列 queue.Queue

import queue
q=queue.Queue(3)
q.put(1)
q.put(2)
print(q.qsize())# 查看当前队列的长度
q.put(3)
try:
    q.put_nowait(4) # 和put效果一样,但是如果队列满了继续放它会报错
except exception:
    print('队列满了,放不进去了')
print(q.full()) # 查看当前队列是否是满的

print(q.get())#1
print(q.get())#2
print(q.get())#3
print(q.get_nowait()) #和get效果一样,但是如果队列空了继续拿会报错
print(q.empty())# 查看当前队列是否是空的

2).先进后出队列 queue.LifoQueue

import queue

q=queue.LifoQueue(3)
q.put(1)
q.put(2)
print(q.qsize())
q.put(3)
q.put_nowait(4)
print(q.full())

print(q.get())#3
print(q.get())#2
print(q.get())#1
print(q.empty()) #查看队列是否是空的
print(q.get_nowait())

3).优先级队列 queue.PriorrityQueue

q=queue.priorityQueue(3)

q.put((2,'alex')) # 必须是元组
q.put((2,'大力')) #数据类型相同才能比较
q.put((-2,'666'))

# 如果值里面的元素是int类型,如果这两个值大小,就先拿比较小的那个;如果这两个值大小相同,
那么比较的是下一个元素的第一个ascii码大小,小的优先被取出来
# 如果元素类型是字符串,那么依次比较每个字母的ascii的大小,小的被优先拿出来
# 字典不能比较
print(q.get())
print(q.get())
print(q.get())

3.线程池

from concurrent_futures import ThreadPoolExecutor,ProcessPoolExecutor

p=ThreadPoolExecutor(3) #默认线程的个数是cpu的个数 *5

p=ProcessPoolExecutor(3) #默认进程的个数是cpu的个数

p.map(f1,可迭代对象) # 异步执行

res=p.submit(f1,无敌传参,传什么都行) #异步提交任务

print(res.result()) #和get方法一样,如果没有结果,会等待,阻塞程序

Shutdown()# close+join ,锁定线程池,等待线程池中的所有已经提交的任务全部执行完毕

import time
from threading import current_thread
from concurrent.futures import ThreadPoolExecutor ,ProcessPoolExecutor

def f1(n):
    time.sleep(1)
    print(f'{n}号子线程')
    print('n')

if __name__=='__main__':
    tp=ThreadPoolExecutor(4)
　　re_list=[]
　　# 方法1 
　　tp.map(f1,range(10))   # 异步提交任务,参数同样时任务名称,可迭代对象，不打乱顺序
　　# 方法2
　　for i in range(10):
　　　　res=tp.submit(f1,i,'baobao')   # submit是给线程池异步提交任务，打乱顺序
　　　　re_list.append(res)
　　for el in re_list:
　　　　print(el.result())

　　print('主线程结束')
　　tp.shutdown()  #主线程等待所有提交给线程池的任务,全部执行完毕 close + join

4.协程

生成器版协程:(有BUG)

import time
def f1():
    for i in range(10):
        time.sleep(1)
        print('f1执行后的结果',i)
        yield

def f2():
    g=f1()
    for i in range(10):
        time.sleep(1)
        print('f2执行后的结果',i)
        next(g)

f1()
f2()

greenlet 版协程

import time
import greenlet
def f1(s):
    print('第一次f1',s)
    g2.switch('alex')# 切换到g2这个对象的任务去执行
    time.sleep(0.4)
    print('第二次f1',s)
    g2.switch('baobao')

def f2(s):
    print('第一次f2',s)
    g1.switch('wusir')
    time.sleep(0.6)
    print('第二次f2',s)
    
g1=greenlet(f1)#实例化对象,并将任务名称作为参数传进去
g2=greenlet(f2)
g1.switch('zhu')# 执行g1对象的任务

gevent版真正的协程(真正意义上的协程,异步执行程序)

import gevent
from gevent import monkey;monkey.patch_all()
import time 
import threading

def f1():
    print('第一次f1')
    gevent.sleep(1)
    print('第二次执行f1')

def f2():
    print('第一次执行f2')
    gevent.sleep(1)
    print('第二次执行f2')

g1=gevent.spawn(f1)
g2=gevent.spawn(f2)
gevent.joinall([g1,g2]) # 相当于g1.join()  g2.join()
print('主程序任务结束')

day34 线程池 协程

day34 线程池协程