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使用中文正则表达式匹配指定中文字符串的方法示例  # 多线程  # 自己的  # 多个  # 于你  # 都是  # 客户端  # 有个  # 我觉得  # 有可能  # 就有  # 最多  # 是这样  # 其他的  # 就没  # 用了  # 希望能  # 三种  # 就不能  # 是说  # 什么呢 

相关栏目： 【 网站优化151355 】 【 网络推广146373 】 【 网络技术251813 】 【 AI营销90571 】

相关推荐： 制作旅游网站html,怎样注册旅游网站？  北京网站制作公司哪家好一点,北京租房网站有哪些？  jQuery 常见小例汇总  Laravel怎么为数据库表字段添加索引以优化查询  深圳网站制作设计招聘,关于服装设计的流行趋势，哪里的资料比较全面？  JavaScript如何实现继承_有哪些常用方法  谷歌Google入口永久地址_Google搜索引擎官网首页永久入口  电视网站制作tvbox接口,云海电视怎样自定义添加电视源？  Laravel怎么实现模型属性转换Casting_Laravel自动将JSON字段转为数组【技巧】  Laravel Eloquent关联是什么_Laravel模型一对一与一对多关系精讲  Win11怎么查看显卡温度 Win11任务管理器查看GPU温度【技巧】  微信小程序 scroll-view组件实现列表页实例代码  Zeus浏览器网页版官网入口 宙斯浏览器官网在线通道  Laravel怎么配置S3云存储驱动_Laravel集成阿里云OSS或AWS S3存储桶【教程】  昵图网官方站入口 昵图网素材图库官网入口  HTML透明颜色代码怎么让图片透明_给img元素加透明色的技巧【方法】  PythonWeb开发入门教程_Flask快速构建Web应用  Firefox Developer Edition开发者版本入口  电商网站制作多少钱一个,电子商务公司的网站制作费用计入什么科目？  如何用搬瓦工VPS快速搭建个人网站？  如何在建站宝盒中设置产品搜索功能？  Laravel怎么进行浏览器测试_Laravel Dusk自动化浏览器测试入门  如何快速上传自定义模板至建站之星？  Laravel如何实现多对多模型关联？（Eloquent教程）  详解MySQL数据库的安装与密码配置  如何在自有机房高效搭建专业网站？  如何自定义建站之星模板颜色并下载新样式？  ,南京靠谱的征婚网站？  如何在宝塔面板中创建新站点？  网站制作报价单模板图片,小松挖机官方网站报价？  Laravel怎么做数据加密_Laravel内置Crypt门面的加密与解密功能  Python结构化数据采集_字段抽取解析【教程】  HTML透明颜色代码在Angular里怎么设置_Angular透明颜色使用指南【详解】  如何用手机制作网站和网页,手机移动端的网站能制作成中英双语的吗？  Laravel storage目录权限问题_Laravel文件写入权限设置  香港服务器网站测试全流程：性能评估、SEO加载与移动适配优化  Laravel如何实现全文搜索功能？（Scout和Algolia示例）  利用python获取某年中每个月的第一天和最后一天  香港服务器部署网站为何提示未备案？  Laravel怎么创建自己的包(Package)_Laravel扩展包开发入门到发布  html如何与html链接_实现多个HTML页面互相链接【互相】  微信小程序 require机制详解及实例代码  laravel服务容器和依赖注入怎么理解_laravel服务容器与依赖注入解析  高性能网站服务器部署指南：稳定运行与安全配置优化方案  Laravel中DTO是什么概念_在Laravel项目中使用数据传输对象(DTO)  Python文件异常处理策略_健壮性说明【指导】  香港网站服务器数量如何影响SEO优化效果？  详解ASP.NET 生成二维码实例（采用ThoughtWorks.QRCode和QrCode.Net两种方式）  如何用AI一键生成爆款短视频文案？小红书AI文案写作指令【教程】  Java Adapter 适配器模式（类适配器，对象适配器）优缺点对比