zoukankan      html  css  js  c++  java
  • python之高性能网络编程并发框架eventlet实例

    http://blog.csdn.net/mingzznet/article/details/38388299

    前言:

    虽然 eventlet 封装成了非常类似标准线程库的形式,但线程和eventlet在实际并发执行流程仍然有明显区别。在没有出现 I/O 阻塞时,除非显式声明,否则当前正在执行的 eventlet 永远不会把 cpu 交给其他的 eventlet,而标准线程则是无论是否出现阻塞,总是由所有线程一起争夺运行资源。所有 eventlet 对 I/O 阻塞无关的大运算量耗时操作基本没有什么帮助。

     

    Eventlet 的基础是 greenlet,这是实现 "协程(Coroutine)" 的基础.协程又被称作 "微线程“,简单点说就是在一个原生线程上通过 "拷贝" 和 "切换" 堆栈帧数据来实现执行多个工作绪.看上去和传统的 "单CPU,多线程(Threading)" 执行方式差不多. swpan() 启动一个 GreenThread 执行目标函数,wait() 返回函数执行结果。


     

    1
    2
    3
    4
    import eventlet
    pool = eventlet.GreenPool()
    while True:
         pool.spawn(func,args )



    上面这段代码,几乎就是使用eventlet的范式:

    GreenPool 用来实现协程,保证并行;

    Spawn 用来调用相应的函数,完成具体业务

    每个func之间切换,实施“你运行一会、我运行一会”,并且在进行切换时必须指定何时切换以及切换到哪,当出现阻塞时,就显式切换到另一段没有被阻塞的代码段执行,直到原先的阻塞状况消失以后,再人工切换回原来的代码段继续处理.

    首先需要安装eventlet的相关模块

    005927259.jpg

    我们先简单跑一个demo !

    011221569.jpg


    他的用法其实和threading差不多的,都可以指定pool和函数的。(有点废话)

    为啥叫他网络编程框架,因为他支持很多底层的东西,比如http,比如socket啥的。

     

    1
    2
    3
    4
    5
    6
    7
    8
    9
    10
    11
    12
    13
    14
    15
    16
    17
    18
    19
    20
    21
    22
    23
    24
    25
    26
    27
    28
    29
    30
    31
    #! /usr/bin/env python
    # -*- coding: UTF-8 -*-
    from eventlet import api
    def httpd(writer,reader):
        req=''
        while True:
            chunk=reader.readline()
            if not chunk:
                break
            req+=chunk
            if chunk==' ':
                break
        data='Hello world! '
        writer.write('HTTP/1.1 200 OK Content-Length: %d %s'%(len(data),data))
        writer.close()
        reader.close()
        return
    def main():
        try:
            server=api.tcp_listener(('0.0.0.0',3000))
            print 'Server started!'
            while True:
                conn,addr=server.accept()
                #print 'client %s connected!'%repr(addr)
                writer=conn.makefile('w')
                api.spawn(httpd,writer,conn.makefile('r'))
        except KeyboardInterrupt:
            pass
        return
    if __name__=='__main__':
        main()


    咱们来测试下这个用eventlet实现的http吧!

    012144447.jpg


    客户端访问下

    012328743.jpg



    下面是利用wait()堵塞行为,保证他是同步的运行。

    170021439.png

  • 相关阅读:
    排序算法
    存储5——逻辑卷管理LVM
    php && 逻辑与运算符使用说明
    php分页代码
    PHP中获取当前页面的完整URL
    php 文件上传后缀名与文件类型对照表(几乎涵盖所有文件)
    生成订单唯一id
    JS 返回上一步(退回上一步上一个网页)
    php实现的太平洋时间和北京时间互转的自定义函数
    php 上传视频的代码
  • 原文地址:https://www.cnblogs.com/jingzhishen/p/3900936.html
Copyright © 2011-2022 走看看