当前位置:
首页 > Python基础教程 >
-
Python手动或自动协程操作方法解析
这篇文章主要介绍了Python手动或自动协程操作方法解析,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的朋友可以参考下
1.手动协程操作:
# pip install gevent
from greenlet import greenlet
def test():
print('He ')
gr2.switch() # 切换到test2
print('a ')
gr2.switch()
def test2():
print('is ')
gr1.switch()
print('student.')
gr1 = greenlet(test) # 创建一个协程
gr2 = greenlet(test2)
gr1.switch() # 切换到gr1,也就是运行它
- 自动协程,遇到I/O自动切换
import gevent
from gevent import monkey; monkey.patch_all() # 导入monkey,给所有支持的模块打上补丁,变成非阻塞模块,也就是使其能够进行协程操作
def test1(n):
print("I'm doing my homework.")
gevent.sleep(n) # 模拟I/O操作,gevent自动切换
print('Keep doing my homework.')
def test2(n):
print("I have no time to watch TV.")
gevent.sleep(n)
print('Stop thinking!')
def test3():
print("Life is hard.")
# 等待 greenlets 全部结束
gevent.joinall([
gevent.spawn(test1,3), # 创建一个新的greeenlet对象,并规划它去执行 test1(3)
gevent.spawn(test2,1),
gevent.spawn(test3),
])
结果:
I'm doing my homework.
I have no time to watch TV.
Life is hard.
Stop thinking!
Keep doing my homework.
- socket 协程实例:
服务器:
import socket
import gevent
from gevent import monkey
monkey.patch_all() # 打补丁,让所有支持的模块变成非阻塞的方法
def server(ip,port):
s = socket.socket() # 生成socket对象
s.bind((ip, port)) # 绑定ip和端口
s.listen() # 设置监听
while True:
cli, addr = s.accept() # 等待连接
gevent.spawn(handle_request, cli) # 对每一个连接,使用协程的方法生成greenlet
def handle_request(conn):
try:
while True:
data = conn.recv(1024) # 接收数据
print("recv:", data)
new = 'Hello '+ data.decode().title()
conn.send(new.encode('utf8')) # 返回数据
if not data:
conn.shutdown(socket.SHUT_WR)
except Exception as e:
print(e)
finally:
conn.close()
if __name__ == '__main__':
server('localhost',9999)
客户端:
import socket
client = socket.socket()
client.connect(('localhost',9999))
while True:
con = input('>>>:').strip()
if len(con) ==0: continue
client.send(con.encode('utf-8'))
data = client.recv(1024)
print(data.decode())
client.close()
以上就是本文的全部内容,希望对大家的学习有所帮助,也希望大家多多支持。
原文链接:https://www.cnblogs.com/wztshine/p/12054120.html
栏目列表
最新更新
求1000阶乘的结果末尾有多少个0
详解MyBatis延迟加载是如何实现的
IDEA 控制台中文乱码4种解决方案
SpringBoot中版本兼容性处理的实现示例
Spring的IOC解决程序耦合的实现
详解Spring多数据源如何切换
Java报错:UnsupportedOperationException in Col
使用Spring Batch实现批处理任务的详细教程
java中怎么将多个音频文件拼接合成一个
SpringBoot整合ES多个精确值查询 terms功能实
SQL Server 中的数据类型隐式转换问题
SQL Server中T-SQL 数据类型转换详解
sqlserver 数据类型转换小实验
SQL Server数据类型转换方法
SQL Server 2017无法连接到服务器的问题解决
SQLServer地址搜索性能优化
Sql Server查询性能优化之不可小觑的书签查
SQL Server数据库的高性能优化经验总结
SQL SERVER性能优化综述(很好的总结,不要错
开启SQLSERVER数据库缓存依赖优化网站性能
uniapp/H5 获取手机桌面壁纸 (静态壁纸)
[前端] DNS解析与优化
为什么在js中需要添加addEventListener()?
JS模块化系统
js通过Object.defineProperty() 定义和控制对象
这是目前我见过最好的跨域解决方案!
减少回流与重绘
减少回流与重绘
如何使用KrpanoToolJS在浏览器切图
performance.now() 与 Date.now() 对比