Python通过poll实现异步IO的方法

作者:raygtr 时间:2023-07-17 04:08:52 

本文实例讲述了Python通过poll实现异步IO的方法。分享给大家供大家参考。具体分析如下:

在使用poll()后返回轮询对象,该对象支持以下方法:
pollObj.register(fd,[,eventmask])第一个参数是注册新的文件描述符fd,fd要么是一个整数文件描述符,要么可以带有一个获取文件描述符的fileno()方法的对象。eventmask是一些按位或标记,这些标记指示要处理的事件。

POLLIN:       用于读取数据
POLLPRI:      用于读取紧急数据
POLLOUT:      准备写入
POLLERR:      错误情况
POLLHUP:      保持状态
POLLNVAL:     无效请求

最后在循环中利用pollObj.poll()来进行对已注册的文件描述符进行轮询。返回一元祖(fd,event)。其中fd是文件描述符,event是指示时间的位掩码。至需要将event与对应的时间进行&测试即可。

利用poll创建对一个多路文件复制程序,代码如下:


#!/usr/bin/env python
import select
BLKSIZE=8192
def readwrite(fromfd,tofd):
 readbuf = fromfd.read(BLKSIZE)
 if readbuf:
   tofd.write(readbuf)
   tofd.flush()
 return len(readbuf)
def copyPoll(fromfd1,tofd1,fromfd2,tofd2):
 #定义需要监听的事件
 READ_ONLY = (select.POLLIN |
      select.POLLPRI |
     select.POLLHUP |
     select.POLLERR )
 totalbytes=0
   if not (fromfd1 or fromfd2 or tofd1 or tofd2) :
   return 0
 fd_dict = {fromfd1.fileno():fromfd1,fromfd2.fileno():fromfd2}
 #创建poll对象p
 p=select.poll()
 #利用poll对象p对需要监视的文件描述符进行注册
 p.register(fromfd1,READ_ONLY)
 p.register(fromfd2,READ_ONLY)
 while True:
 #轮询已经注册的文件描述符是否已经准备好
   result = p.poll()
   if len(result) != 0:
     for fd,events in result:
       if fd_dict[fd] is fromfd1:
         if events & (select.POLLIN|select.POLLPRI):
           bytesread = readwrite(fromfd1,tofd1)
           totalbytes+=bytesread
         elif events & (select.POLLERR):
           p.unregister(fd_dict[fd])
       if fd_dict[fd] is fromfd2:
         if events & (select.POLLIN|select.POLLPRI):
           bytesread = readwrite(fromfd2,tofd2)
           totalbytes+=bytesread
         elif events & (select.POLLERR):
           p.unregister(fd_dict[fd])
   if bytesread <= 0:  
     break
 return totalbytes
def main():
 fromfd1 = open("/etc/fstab","r")
 fromfd2 = open("/root/VMwareTools-8.8.1-528969.tar.gz","r")
 tofd1 = open("/root/fstab","w+")
 tofd2 = open("/var/passwd","w+")
 totalbytes = copyPoll(fromfd1,tofd1,fromfd2,tofd2)
 print "Number of bytes copied %d\n" % totalbytes
 return 0
if __name__=="__main__":
 main()

希望本文所述对大家的Python程序设计有所帮助。

标签:Python,poll,IO
0
投稿

猜你喜欢

  • asp如何实现按照输入汉字提示拼音功能?

    2010-05-18 18:37:00
  • 浏览器事件循环与vue nextTicket的实现

    2024-05-09 09:25:26
  • php插件功能实现方法介绍

    2023-05-30 12:28:52
  • 用python计算文件的MD5值

    2023-06-20 21:28:27
  • 如何理解python对象

    2022-09-04 06:58:54
  • 微信小程序canvas写字板效果及实例

    2024-04-19 09:44:03
  • js获取select标签选中值的两种方式

    2024-04-19 09:50:18
  • Python数字图像处理之霍夫线变换实现详解

    2022-01-26 05:59:13
  • 细化解析:MySQL+Webmin轻松创建数据库

    2009-01-14 13:13:00
  • NopCommerce架构分析(一)Autofac依赖注入类生成容器

    2023-07-11 21:20:27
  • python中for用来遍历range函数的方法

    2022-01-28 03:04:53
  • python中pip的安装与使用教程

    2021-06-10 23:37:36
  • python字典的setdefault的巧妙用法

    2021-05-18 02:58:48
  • javascript trim、left、right等函数,兼容IE,FireFox

    2009-09-18 14:55:00
  • 用Oracle并行查询发挥多CPU的威力

    2010-07-23 12:52:00
  • 请给PNG8一个机会:对png8的误解

    2009-09-21 10:45:00
  • python爬虫Scrapy框架:媒体管道原理学习分析

    2022-11-23 15:07:03
  • Python range、enumerate和zip函数用法详解

    2021-06-29 22:24:06
  • python+gdal+遥感图像拼接(mosaic)的实例

    2023-02-22 23:40:34
  • 详解ES6之async+await 同步/异步方案

    2023-08-24 11:10:54
  • asp之家 网络编程 m.aspxhome.com