zoukankan      html  css  js  c++  java
  • python编程(python开发的三种运行模式)【转】

    转自:http://blog.csdn.net/feixiaoxing/article/details/53980886

    版权声明:本文为博主原创文章,未经博主允许不得转载。
    
    目录(?)[-]
    
        单循环模式
        多线程模式
        reactor模式
    
    【 声明:版权所有,欢迎转载,请勿用于商业用途。 联系信箱:feixiaoxing @163.com】
    
      Python作为一门脚本语言,使用的范围很广。有的同学用来算法开发,有的用来验证逻辑,还有的作为胶水语言,用它来粘合整个系统的流程。不管怎么说,怎么使用python既取决于你自己的业务场景,也取决于你自己的python应用能力。就我个人而言,我觉得python作为既可以用来进行业务的开发,也可以进行产品原型的开发.一般来说,python的运行主要下面这三种模式。
    1.单循环模式
    
      单循环模式使用的最多,也最简单,当然也最稳定。为什么呢,因为单循环本来代码就写的很少,出错的机会就更少,所以一般只要写对了接口,犯错误的机会还是很低的。当然,我们不是说单循环就没什么用,恰恰相反。单循环模式是我们最经常使用的一种模式。这种开发对于一些小工具、小应用、小场景特别合适。
    
    #!/usr/bin/python
    import os
    import sys
    import re
    import signal
    import time
    
    g_exit = 0
    
    def sig_process(sig, frame):
        global g_exit
        g_exit = 1
        print 'catch signal'
    
    def main():
        global g_exit
        signal.signal(signal.SIGINT, sig_process)
        while 0 == g_exit:
            time.sleep(1)
    
            '''
            module process code
            ''' 
    
    if __name__ == '__main__':
        main()
    
    
    2.多线程模式
    
      多线程模式经常用在那些容易阻塞的场合。比如多线程客户端读写,多线程web访问等等。这里的多线程有个特点,那就是每个线程都是按照客户端创建的。简单的举例就是服务器socket,来一个socket创建一个thread,这样如果存在多个用户的话,就有多个thread并发连接。这种方式比较简单,用起来很快,缺点就是所有业务有可能并发执行,全局数据保护起来很麻烦。
    
    #!/usr/bin/python
    import os
    import sys
    import re
    import signal
    import time
    import threading
    
    g_exit=0
    
    def run_thread():
        global g_exit
        while 0 == g_exit:
            time.sleep(1)
    
            '''
            do jobs per thread
            '''
    
    def sig_process(sig, frame):
        global g_exit
        g_exit = 1
    
    def main():
    
        global g_exit
    
        signal.signal(signal.SIGINT, sig_process)
        g_threads = []
        for i in range(4):
            td = threading.Thread(target = run_thread)
            td.start()
            g_threads.append(td)
    
        while 0 == g_exit:
            time.sleep(1)
    
        for i in range(4):
            g_threads[i].join()
    
    
    if __name__ == '__main__':
        main()
    
    
    3.reactor模式
    
      reactor模式,不复杂,简单的来说,就是利用多线程来处理每一个业务。如果一个业务已经被某一个thread处理了,那么其他的thread就不能再次处理这个业务了。这样,它相当于解决了一个问题,也就是我们在前面所说的锁的问题。因此,对于这种模式的开发者来说,编写业务其实是一件简单的事情,因为他所要关注的只是自己的一亩三分地就可以了。之前云风同学编写的skynet就是这么一种模式,只不过它使用了c+lua来开发的。其实只要了解了reactor模式本身,用什么语言开发不重要,关键是理解reactor的精髓就可以了。
    
      如果写成code,那应该是这样的,
    
    #!/usr/bin/python
    
    import os
    import sys
    import re
    import time
    import signal
    import threading
    
    g_num = 4
    g_exit =0
    g_threads = []
    g_sem = []
    g_lock = threading.Lock()
    g_event = {}
    
    def add_event(name, data):
        global g_lock
        global g_event
    
        if '' == name:
            return
    
        g_lock.acquire()
        if name in g_event:
            g_event[name].append(data)
            g_lock.release()
            return
    
        g_event[name] = []
    
        '''
        0 means idle, 1 means busy
        '''
        g_event[name].append(0)
        g_event[name].append(data)
        g_lock.release()
    
    def get_event(name):
        global g_lock
        global g_event
    
        g_lock.acquire()
        if '' != name:
            if [] != g_event[name]:
                if 1 != len(g_event[name]):
                    data = g_event[name][1]
                    del g_event[name][1]
                    g_lock.release()
                    return name, data
                else:
                    g_event[name][0] = 0
    
        for k in g_event:
            if 1 == len(g_event[k]):
                continue
    
            if 1 == g_event[k][0]:
                continue
    
            g_event[k][0] =1
            data = g_event[k][1]
            del g_event[k][1]
            g_lock.release()
            return k, data
    
        g_lock.release()
        return '', -1
    
    def sig_process(sig, frame):
        global g_exit
        g_exit =1
        print 'catch signal'
    
    def run_thread(num):
        global g_exit
        global g_sem
        global g_lock
    
        name = ''
        data = -1
    
        while 0 == g_exit:
            g_sem[num].acquire()
    
            while True: 
                name, data = get_event(name)
                if '' == name:
                    break
    
                g_lock.acquire()
                print name, data
                g_lock.release()
    
    
    def test_thread():
        global g_exit
    
        while 0 == g_exit:
            for i in range(100):
                add_event('1', (i << 2) + 0)
                add_event('2', (i << 2) + 1)
                add_event('3', (i << 2) + 2)
                add_event('4', (i << 2) + 3)
    
            time.sleep(1)
    
    
    def main():
        global g_exit
        global g_num
        global g_threads
        global g_sem
    
        signal.signal(signal.SIGINT, sig_process)
        for i in range(g_num):
            sem = threading.Semaphore(0)
            g_sem.append(sem)
            td = threading.Thread(target=run_thread, args=(i,))
            td.start()
            g_threads.append(td)
    
        '''
        test thread to give data
        '''
        test = threading.Thread(target=test_thread)
        test.start()
    
        while 0 == g_exit:
            for i in range(g_num):
                g_sem[i].release()
            time.sleep(1)
    
        '''
        call all thread to close
        '''
        for i in range(g_num):
            g_sem[i].release()
    
        for i in range(g_num):
            g_threads[i].join()
    
        test.join()
        print 'exit now'
    
    '''
    entry
    '''
    if __name__ == '__main__':
        main()
  • 相关阅读:
    移动开发学习touchmove
    webapp利用iscroll实现同时横滚|竖滚
    centos配置备忘(apachephpmysql)
    VMware ESXi 配置小结
    【C语言程序设计】C语言求自守数(详解版)
    世界500强企业面试题:猴子吃香蕉!这是人能想出来的答案?
    【C语言程序设计】C语言判断三角形的类型!
    拿什么来衡量程序员的生产力!代码量?开发速度?忙碌的状态?都不是!
    如果你拿到蚂蚁p7的offer,但是你正在国企拿着60+,你会如何选择?
    【C语言程序设计】汉诺塔问题,用C语言实现汉诺塔!
  • 原文地址:https://www.cnblogs.com/sky-heaven/p/6803514.html
Copyright © 2011-2022 走看看