python使用多线程写生成器_Python学习——多线程,异步IO,生成器,协程

Python的语法是简洁的,也是难理解的。

比如yield关键字:

def fun():

for i in range(5):

print('test')

x = yield i

print('good', x)

if __name__ == '__main__':

a = fun()

# print(a.__next__())

# print(a.__next__())

# print(a.__next__())

y = a.send(None)

y = a.send(-1)

y = a.send(-2)

#print(y)

凡是包含yield关键字的函数都不再是一个函数,而成为一个生成器(或迭代器,Generator)

Generator包含一个栈帧(Stack Frame),它维护Generator自身的执行状态,即便生成器的执行被暂停而返回到母程序中,下一次依然能恢复Generator的上一次的状态,从一个yield执行到下一个yield语句前。这就是生成器的执行方式。

迭代一个执行器可以使用send方法,也可以使用__next__方法,send方法能给Generator传递即时的数据,同时接收Generator内部执行状态,这个过程就是协程通信的基础。

而__next__方法只能从Generator接收内部执行状态,而无法向Generator中传入信息,所以__next__不能完成通信,因为通信不能是单向的。

__next__调用下的Generator只是一个迭代器而已。而send调用下的Generator却升级成为一个协程(Co-routine)

使用协程Coroutine的目的是为了避免将业务逻辑的实现混在异步IO的回调函数中,使得程序可读性提升而已。

Python中异步IO采用selectors,它支持了各个操作系统的异步IO的事件管理机制(Linux是epoll),通过selectors.DefaultSelector来实现事件与回调函数的绑定。可以将线程内CPU等待IO的时间转移到操作系统上。毕竟和IO设备交互的不是应用程序,而是操作系统。

多线程:

import threading, time

global n

class MyThread(threading.Thread):

def __init__(self):

threading.Thread.__init__(self)

def run(self):

global n, lock

time.sleep(1)

if lock.acquire():

print(n)

print(self.name)

n += 1

lock.release()

if __name__ == '__main__':

n = 1

ThreadList = []

lock = threading.Lock()

for i in range(1, 200):

t = MyThread()

ThreadList.append(t)

for t in ThreadList:

t.start()

for t in ThreadList:

t.join()

多线程简单,需要注意的就是锁。资源的访问在锁中进行时,锁才会起作用,因此这个锁类似于独立于线程的原子性对象,所有线程都在这个锁上变得有序起来,离开锁重归无序竞争状态。

因此资源无所谓唯一性和不可同时操作性,只有锁自身具备这种性质。所有的资源的同步都是靠代码的约束——将和资源相关的操作和锁绑定在一起才能实现的。多线程在一般设备上效率不逊于协程(单线程内通过操作系统OS进行执行顺序的切换)。

本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若转载,请注明出处:http://www.mzph.cn/news/373748.shtml

如若内容造成侵权/违法违规/事实不符,请联系多彩编程网进行投诉反馈email:809451989@qq.com,一经查实,立即删除!

相关文章

Python与C++结构体交互

需求:根据接口规范,实现与服务端的数据交互 服务端结构体分包头、包体、包尾 包头C结构体示例如下 1 typedef struct head2 {3 BYTE string1;4 BYTE string2; //包类型5 BYTE string3; //版本号,目前为06 char s…

Ubuntu下安装OpenSSH Server并在客户端远程连接Ubuntu

本文主要是向读者介绍了如何在Ubuntu系统下安装OpenSSH Server并在客户端远程连接Ubuntu,共有两种方法,一种是命令行安装;另一种是通过Ubuntu Software Center安装,希望对大家能有帮助! 方法一(推荐&#…

算法:老鼠走迷宫问题

算法:老鼠走迷宫问题(初) 【写在前面】 老鼠走迷宫问题的递归实现,是对递归思想的一种应用。 【问题描述】 给定一个二维数组,数组中2表示墙壁,0表示通路,由此数组可展示为一个迷宫图。给定入口位置和出口位置&#xf…

rust python对比_Python Rust 迭代器对比

迭代是数据处理的基石,而 Python 中所有集合都可以迭代,这是 Python 让使用者感到非常方便的特征之一。下面是一些在 Python 中经常使用的迭代模式# 列表for i in [1, 2, 3, 4]:print(i)# 字典di {a: 1, b: 2, c: 3}# 迭代键for k in di.keys():print(k…

WebSphere Application Server性能调整工具包

IBM已发布了WebSphere Application Server性能调整工具包 ,该工具包具有从Eclipse工作区*监视多个 WebSphere Application Server的功能。 该工具使用WAS Performance Monitoring统计信息来获取并绘制图表,以指示服务器的运行状况。 *请注意,…

CentOS 配置防火墙操作实例(启、停、开、闭端口)

CentOS 配置防火墙操作实例&#xff08;启、停、开、闭端口&#xff09;&#xff1a; 注&#xff1a;防火墙的基本操作命令&#xff1a; 查询防火墙状态: [rootlocalhost ~]# service iptables status<回车> 停止防火墙: [rootlocalhost ~]# service iptables stop &…

linux常用命令-压缩解压命令

压缩解压命令 目录 1. 压缩解压命令&#xff1a;gzip 2. 压缩解压命令&#xff1a;gunzip 3. 压缩解压命令&#xff1a;tar 4. 压缩解压命令&#xff1a;zip 5. 压缩解压命令&#xff1a;unzip 6. 压缩解压命令&#xff1a;bzip2 7. 压缩解压命令&#xff1a;bunzip2 1. 压缩解…

达梦数据库查询数据库所有表名_达梦数据库的一些实用小SQL

1)当前数据库中的模式名&#xff1a;select distinct object_name TABLE_SCHEMA from all_objects where object_type SCH;2)查出各模式对应的用户&#xff1a;selectSCH_OBJ.NAME ,SCH_OBJ.ID ,SCH_OBJ.CRTDATE,USER_OBJ.NAMEfrom(select NAME, ID, PID, CRTDATE from …

设置Java EE 6开发环境

本教程简要说明了如何设置典型的环境来开发基于Java EE 6的应用程序。 除了可以正常工作的Windows XP客户端具有足够的CPU能力和内存外&#xff0c;本教程没有其他先决条件。 在教程中&#xff0c;我们将需要安装以下组件&#xff1a; Java 6 JDK更新26 用于Java EE开发人员的…

css cursor url用法格式详解

css cursor url用法格式&#xff1a;css:{cursor:url(图标路径),auto;} //IE,FF,chrome浏览器都可以 实例代码&#xff1a;html{cursor: url("http://ued.taobao.com/blog/wp-content/themes/taobaoued/images/cursor.ico"),auto;} 解析&#xff1a;前面的url是自定义…

iostext添加点击事件_iOS开发小技巧 - label中的文字添加点击事件

Label中的文字添加点击事件以前老师讲过类似的功能,自己懒得回头看了,找了很多第三方的,感觉这个小巧便利,作者只是扩展了分类,实现起来代码也少.先来个效果图自己的项目,直接上代码- (void)setTopicModel:(CYQTopicModel *)topicModel{_topicModel topicModel;NSArray *likeA…

ubantu下安装Nginx

Nginx 概述 Nginx ("engine x") 是一个高性能的 HTTP 和 反向代理 服务器&#xff0c;也是一个 IMAP/POP3/SMTP 代理服务器。 Nginx 是由 Igor Sysoev 为俄罗斯访问量第二的 Rambler.ru 站点开发的&#xff0c;第一个公开版本0.1.0发布于2004年10月4日。其将源代码…

Hadoop中的问题–何时无法交付?

Hadoop是很棒的软件。 它不是原始的&#xff0c;但肯定不能消除它的荣耀。 它建立在并行处理的基础上&#xff0c;这个概念已经存在了数十年。 Hadoop虽然从概念上来说并不是独创性的&#xff0c;但它显示了自由开放的力量&#xff08;就像在啤酒中一样&#xff01;&#xff09…

创建 dblink

目的&#xff1a;oracle中跨数据库查询 两台数据库服务器db_A(本地)和db_B(远程192.168.1.100)&#xff0c;db_A下用户user_a 需要访问到db_B下user_b的数据解决&#xff1a;查询得知使用dblink(即database link 数据库链)实现过程&#xff1a;1、确定用户user_a有没有创…

C#静态常量和动态常量的区别

C#拥有两种不同的常量&#xff1a;静态常量(compile-time constants)和动态常量(runtime constants)。它们有不同的特性&#xff0c;错误的使用不仅会损失效率&#xff0c;还可能造成错误。相比之下&#xff0c;静态常量在速度上会稍稍快一些&#xff0c;但是灵活性却比动态常…

spring的钩子_高级java开发必须掌握的Spring接口——SmartLifecycle

有些场景我们需要在Spring 所有的bean 完成初始化后紧接着执行一些任务或者启动需要的异步服务。 常见有几种解决方案j2ee 注解 启动前PostConstruct 销毁前PreDestroy 基于j2ee 规范springboot 的 org.springframework.boot.CommandLineRunner springboot 特性前面我已经介绍过…

Java:对Java SE 6和Java SE 7的客户端和桌面部分的改进!

Java 6和Java 7中的客户端改进 了解有关Java SE 6和Java SE 7的客户端和桌面部分的改进&#xff0c;包括新的applet插件&#xff0c;Java Deployment Toolkit&#xff0c;成形和半透明的窗口&#xff0c;重量级-轻量级混合以及Java Web Start。 介绍 自2006年12月发布Java平台…

辨异 —— 行星 vs 恒星

star&#xff1a;恒星&#xff0c;planet&#xff1a;行星&#xff1b;1. 恒星 恒星是指宇宙中靠核聚变产生的能量而自身能发热发光的星体&#xff08;比如太阳&#xff09;。过去天文学家以为恒星的位置是永恒不变的&#xff0c;以此为名。但事实上&#xff0c;恒星也会按照一…

软件公司职责分配

岗位&#xff1a;项目经理 主要职责&#xff1a;1、 计划&#xff1a;a)项目范围、项目质量、项目时间、项目成本的确认。b)项目过程/活动的标准化、规范化。c)根据项目范围、质量、时间与成本的综合因素的考虑&#xff0c;进行项目的总体规划与阶段计划。d)各项计划得到上级领…

大型网站架构系列:负载均衡详解(4)

本文是负载均衡详解的第四篇&#xff0c;主要介绍了LVS的三种请求转发模式和八种负载均衡算法&#xff0c;以及Haproxy的特点和负载均衡算法。具体参考文章&#xff0c;详见最后的链接。 三、LVS负载均衡 LVS是一个开源的软件&#xff0c;由毕业于国防科技大学的章文嵩博士于19…