python类中的数据封装(基于python生成器封装的协程类)
类别:脚本大全 浏览量:117
时间:2021-11-03 15:13:20 python类中的数据封装
基于python生成器封装的协程类自从python2.2提供了yield关键字之后,python的生成器的很大一部分用途就是可以用来构建协同程序,能够将函数挂起返回中间值并能从上次离开的地方继续执行。python2.5的时候,这种生成器更加接近完全的协程,因为提供了将值和异常传递回到一个继续执行的函数中,当等待生成器的时候,生成器能返回控制。
python提供的生成器设施:
- yield:能够将自己挂起,并提供一个返回值给等待方
- send:唤起一个被挂起的生成器,并能够传递一个参数,可以在生成器中抛出异常
- next:本质上相当于send(None),对每个生成器的第一次调用必须不能传递参数
- close:主动退出一个生成器
python封装
虽然python3提供了asyncio这样的异步IO库,而且也有greenlet等其他协程库,但目前的需求并不是实际的网络IO并发操作,而是需要模拟状态机的运行,因此使用协程可以很方便的模拟,并加入认为的控制,下面是封装的一个python类。
|
class Coroutine( object ): """ Base class of the general coroutine object """ STATE_RUNNING = 0 STATE_WAITING = 1 STATE_CLOSING = 2 def __init__( self ): self .state = Coroutine.STATE_WAITING self .started = False self .args = None self .routine = self ._co() def _co( self ): self .ret = None while True : self .args = yield self .ret if not self .started: self .started = True continue else : self .state = Coroutine.STATE_RUNNING self .ret = self .run( self .args) if self .state = = Coroutine.STATE_CLOSING: break self .state = Coroutine.STATE_WAITING def start( self ): """ Start the generator """ if self .routine is None : raise RuntimeError( 'NO task to start running!' ) self .started = True self .routine. next () def finish( self ): """ Finish the execution of this routine """ self .state = Coroutine.STATE_CLOSING self .routine.close() def run( self , args): """ The runing method to be executed every once time""" raise NotImplementedError def execute( self , arg_obj): """ Awake this routine to execute once time """ return self .routine.send(arg_obj) |
基于上述封装,下面实现了一个协同的生产者消费者示例:
|
class ProducerCoroutine(Coroutine): """ The Producer concrete coroutine """ def __init__( self , cnsmr): if not isinstance (cnsmr, Coroutine): raise RuntimeError( 'Consumer is not a Coroutine object' ) self .consumer = cnsmr self .consumer.start() super (ProducerCoroutine, self ).__init__() def run( self , args): print 'produce ' , args ret = self .consumer.execute(args) print 'consumer return:' , ret def __call__( self , args): """ Custom method for the specific logic """ self .start() while len (args) > 0 : p = args.pop() self .execute(p) self .finish() class ConsumerCoroutine(Coroutine): """ The Consumer concrete coroutine """ def __init__( self ): super (ConsumerCoroutine, self ).__init__() def run( self , args): print 'consumer get args: ' , args return 'hahaha' + repr (args) |
运行结果如下:
|
produce 4 consumer get args: 4 consumer return : hahaha4 produce 3 consumer get args: 3 consumer return : hahaha3 produce 2 consumer get args: 2 consumer return : hahaha2 produce 1 consumer get args: 1 consumer return : hahaha1 produce 0 consumer get args: 0 consumer return : hahaha0 |
以上就是本文的全部内容,希望对大家的学习有所帮助,也希望大家多多支持开心学习网。
原文链接:https://blog.csdn.net/u010487568/article/details/62042709
您可能感兴趣
- pythonyield有什么用(彻底理解Python中的yield关键字)
- python读取文件的正确方法(强悍的Python读取大文件的解决方案)
- python中if条件语句如何使用(Python中如何使用if语句处理列表实例代码)
- python删除列表中的重复元素(Python实现去除列表中重复元素的方法总结7种方法)
- python多线程多进程运行场景(Python多线程同步---文件读写控制方法)
- python如何获取列表值(Python中按键来获取指定的值)
- python采集微信电脑端聊天信息(利用Python实现微信找房机器人实例教程)
- python format的用法(Python中format格式输出全解)
- python参模块使用教程(Python参数解析模块sys、getopt、argparse使用与对比分析)
- 如何对python中列表中的数据运算(Python3.5集合及其常见运算实例详解)
- python微信红包分配(PHP切割整数工具类似微信红包金额分配的思路详解)
- python里面的print怎么用(python中的print输出)
- python实用教程(Python简直是万能的,这5大主要用途你一定要知道!推荐)
- python多线程和多进程应用场景(Python多线程处理实例详解单进程/多进程)
- python搭建django框架(详解Python网络框架Django和Scrapy安装指南)
- python操作json格式(详解python 3.6 安装json 模块simplejson)
- 白T恤穿法(白t恤)
- 你怎么忘了是说先爱我(你怎么忘了如何爱我)
- 做技术难吗(技术难不难)
- 林心如是谁(林心如是谁演的)
- 泰国安全吗(泰国安全吗2023)
- 菲律宾安全吗(菲律宾安全吗)
热门推荐
- SQLServer中防止并发插入重复数据的方法详解(SQLServer中防止并发插入重复数据的方法详解)
- 云计算是一种服务的概念(云服务的意思,云服务是云计算吗?)
- js return false的作用
- sqlserver查看某个库所有表(SQL Server怎么找出一个表包含的页信息Page)
- 互联网云服务器需要配置(视频云服务器的配置一般怎么选?)
- Asp.Net实现网站的快捷方式
- mysql中json的支持(MySQL中json字段的操作方法)
- mysql触发器入门(MySQL中触发器和游标的介绍与使用)
- class对应的css(CSS的class与id常用的命名规则)
- docker怎么搭建私有服务器(docker搭建CMS点播系统带播放器功能)
排行榜
- 1
- 2
- 3
- 4
- 5
- 6
- 7
- 8
- 9