菜单

Python并发编制程序之协程

2019年9月26日 - 皇家赌场系统

Greenlet

#安装pip3 install greenlet

from greenlet import greenletdef eat:    print('%s eat 1' %name)    g2.switch('egon')    print('%s eat 2' %name)    g2.switch()def play:    print('%s play 1' %name)    g1.switch()    print('%s play 2' %name)g1=greenletg2=greenletg1.switch('egon')#可以在第一次switch时传入参数,以后都不需要

greenlet只是提供了一种比generator越发简便易行的切换格局,当切换来八个任务实施时如果蒙受IO,那就原地阻塞,任然未有减轻际遇IO自动切换成升高功能的标题。

Gevent之一同与异步

图片 1图片 2

from gevent import spawn,joinall,monkey;monkey.patch_all()import timedef task:    """    Some non-deterministic task    """    time.sleep(0.5)    print('Task %s done' % pid)def synchronous():    for i in range(10):        taskdef asynchronous():    g_l=[spawn for i in range(10)]    joinallif __name__ == '__main__':    print('Synchronous:')    synchronous()    print('Asynchronous:')    asynchronous()#上面程序的重要部分是将task函数封装到Greenlet内部线程的gevent.spawn。 初始化的greenlet列表存放在数组threads中,此数组被传给gevent.joinall 函数,后者阻塞当前流程,并执行所有给定的greenlet。执行流程只会在 所有greenlet执行完后才会继续向下走。

View Code

协程介绍

协程:是单线程下的产出,又称微线程,纤程。协程是一种客户态的轻量级线程,即线程是由客户程序自个儿调控调节的。

供给重申的是:

#1. python的线程属于内核级别的,即由操作系统控制调度(如单线程遇到io或执行时间过长就会被迫交出cpu执行权限,切换其他线程运行)#2. 单线程内开启协程,一旦遇到io,就会从应用程序级别控制切换,以此来提升效率(!!!非io操作的切换与效率无关)

对待操作系统调整线程的切换,客户在单线程内决定线程的切换

亮点如下:

1.
线程的切换开销更加小,属于线程级其他切换,操作系统完全感知不到,由此尤其轻量级

  1. 单线程内就能够兑现产出的效果,最大限度的应用cpu

劣点如下:

1.
线程的真相是单线程下,不可能采用多核,能够是一个线程开启两个进度,每一个进度内展开四个线程,每个线程内展开协程

  1. 协程指的是单个线程,一旦线程出现堵塞,将会堵塞整个线程

小结线程的风味:

1 必需在唯有叁个单线程里完成产出

2 修改分享数据不需加锁
3 顾客线程里相濡相呴同保护留三个调节流的左右文酒馆

4增大:叁个线程蒙受IO操作自动切换来其余协程(怎样兑现检查评定IO,yield,greenlet都无助落到实处,就用到gevent模块)

Gevent介绍:

#安装pip3 install gevent

Gevent
是三个第三方库,可以轻易通过gevent完结产出同步或异步编制程序,在gevent中用到的主要形式是Greenlet,
它是以C增加模块格局接入Python的轻量级协程。
Greenlet全部周转在主程序操作系统进程的个中,但它们被同盟式地调整。

#用法g1=gevent.spawn(func,1,,2,3,x=4,y=5)创建一个协程对象g1,spawn括号内第一个参数是函数名,如eat,后面可以有多个参数,可以是位置实参或关键字实参,都是传给函数eat的g2=gevent.spawng1.join() #等待g1结束g2.join() #等待g2结束#或者上述两步合作一步:gevent.joinallg1.value#拿到func1的返回值

遇到IO阻塞时会自动切换任务

图片 3图片 4

import geventdef eat:    print('%s eat 1' %name)    gevent.sleep(2)    print('%s eat 2' %name)def play:    print('%s play 1' %name)    gevent.sleep(1)    print('%s play 2' %name)g1=gevent.spawn(eat,'egon')g2=gevent.spawn(play,name='egon')g1.join()g2.join()#或者gevent.joinallprint('主')

View Code

上例gevent.sleep模拟的是gevent能够识别的io阻塞,

而time.sleep或其余的围堵,gevent是不能够一直识别的内需用上边一行代码,打补丁,就足以辨认了

from gevent import
monkey;monkey.patch_all()必需置于被打补丁者的前面,如time,socket模块以前

抑或大家大约回想成:要用gevent,须求将from gevent import
monkey;monkey.patch_all()放到文件的先河

图片 5图片 6

from gevent import monkey;monkey.patch_all()import geventimport timedef eat():    print('eat food 1')    time.sleep(2)    print('eat food 2')def play():    print('play 1')    time.sleep(1)    print('play 2')g1=gevent.spawng2=gevent.spawn(play_phone)gevent.joinallprint('主')

View Code

相关文章

发表评论

电子邮件地址不会被公开。 必填项已用*标注

网站地图xml地图