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 线程池 协程

最新文章

热门文章

day34 线程池协程