python 开发的三种运行模式详细介绍

Python 三种运行模式

  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()

感谢阅读，希望能帮助到大家，谢谢大家对本站的支持！

# Python  # 三种运行模式  # 三种运行模式详细介绍  # 运行模式  # Python的Flask框架及Nginx实现静态文件访问限制功能  # Python的Bottle框架中返回静态文件和JSON对象的方法  # 使用nodejs、Python写的一个简易HTTP静态文件服务器  # python中实现迭代器（iterator）的方法示例  # Python中二维列表如何获取子区域元素的组成  # python解决汉字编码问题：Unicode Decode Error  # Python 3.x 连接数据库示例（pymysql 方式）  # 一步步教你用Python实现2048小游戏  # python django 访问静态文件出现404或500错误  # Python使用中文正则表达式匹配指定中文字符串的方法示例  # 多线程  # 自己的  # 多个  # 于你  # 都是  # 客户端  # 有个  # 我觉得  # 有可能  # 就有  # 最多  # 是这样  # 其他的  # 就没  # 用了  # 希望能  # 三种  # 就不能  # 是说  # 什么呢 

相关文章： 网站制作多少钱一个,建一个论坛网站大约需要多少钱？  如何在阿里云虚拟服务器快速搭建网站？  如何通过虚拟机搭建网站？详细步骤解析  如何通过宝塔面板实现本地网站访问？  C++如何将C风格字符串（char*）转换为std::string？（代码示例）  C#如何序列化对象为XML XmlSerializer用法  如何在Golang中使用replace替换模块_指定本地或远程路径  武汉网站如何制作,黄黄高铁武穴北站途经哪些村庄？  教育培训网站制作流程,请问edu教育网站的域名怎么申请？  深圳网站制作的公司有哪些,dido官方网站？  企业宣传片制作网站有哪些,传媒公司怎么找企业宣传片项目？  如何在万网开始建站？分步指南解析  企业微网站怎么做,公司网站和公众号有什么区别？  建站之星×万网：智能建站系统+自助建站平台一键生成  武汉外贸网站制作公司,现在武汉外贸前景怎么样啊？  网站制作专业公司有哪些,如何制作一个企业网站，建设网站的基本步骤有哪些？  广州商城建站系统开发成本与周期如何控制？  如何在万网自助建站平台快速创建网站？  如何高效配置香港服务器实现快速建站？  青岛网站设计制作公司,查询青岛招聘信息的网站有哪些？  网页设计与网站制作内容,怎样注册网站？  如何选择适配移动端的WAP自助建站平台？  太平洋网站制作公司,网络用语太平洋是什么意思？  贸易公司网站制作流程,出口贸易网站设计怎么做？  网站app免费制作软件,能免费看各大网站视频的手机app？  西安制作网站公司有哪些,西安货运司机用的最多的app或者网站是什么？  Python如何创建带属性的XML节点  郑州企业网站制作公司,郑州招聘网站有哪些？  网站制作说明怎么写,简述网页设计的流程并说明原因？  如何在IIS7上新建站点并设置安全权限？  宠物网站制作html代码,有没有专门介绍宠物如何养的网站啊？  厦门模型网站设计制作公司,厦门航空飞机模型掉色怎么办？  网站制作的步骤包括,正确网址格式怎么写？  品牌网站制作公司有哪些,买正品品牌一般去哪个网站买？  学校为何禁止电信移动建设网站？  高防网站服务器：DDoS防御与BGP线路的AI智能防护方案  建站之星后台管理系统如何操作？  东莞专业制作网站的公司,东莞大学生网的网址是什么？  高端建站如何打造兼具美学与转化的品牌官网？  建站之星安装失败：服务器环境不兼容？  宝塔建站后网页无法访问如何解决？  如何快速搭建二级域名独立网站？  专业企业网站设计制作公司,如何理解商贸企业的统一配送和分销网络建设？  广东专业制作网站有哪些,广东省能源集团有限公司官网？  宝华建站服务条款解析：五站合一功能与SEO优化设置指南  网站专业制作公司有哪些,做一个公司网站要多少钱？  潍坊网站制作公司有哪些,潍坊哪家招聘网站好？  如何快速查询域名建站关键信息？  如何在阿里云域名上完成建站全流程？  简单实现Android验证码