实例详解Python的进程,线程和协程

import os from multiprocessing import Process import time def pro_func(name,age,**kwargs): print("进程正在运行,name=%s, age=%d, pid=%d" %(name, age, os.getpid())) print('kwargs参数值',kwargs) time.sleep(0.1) if __name__=="__main__": p=Process(target=pro_func,args=('Friendship',18),kwargs={'爱好':'Python'}) print('启动进程') p.start() print('程是否还在活着:',p.is_alive())# 判断进程进程是否还在活着 time.sleep(0.5) # 1 秒钟之后，立刻结束进程 print('结束进程') p.terminate() # 不管任务是否完成，立即终止进程 p.join() # 等待子进程执行结束 print('程是否还在活着:',p.is_alive())# 判断进程进程是否还在活着 

import os import time import random from multiprocessing import Process,Queue # 写数据函数 def write(q): for value in ['I','love','Python']: print('在队列里写入 %s ' % value) q.put(value) time.sleep(random.random()) # 读数据函数 def read(q): while True: if not q.empty(): value  = q.get(True) print('从队列中读取 %s ' % value) time.sleep(random.random()) else: break if __name__=="__main__": # 主进程 # 主进程创建 Queue，并传给各个子进程 q=Queue() # 创建两个进程 pw=Process(target=write,args=(q,)) pr=Process(target=read,args=(q,)) # 启动子进程 pw pw.start() # 等待 pw结束 pw.join() # 启动子进程 pr pr.start() # 等待 pw结束 pr.join() print('End!') 

from multiprocessing import Manager,Pool import os,time,random def read(q): print("read进程 启动(%s),主进程为(%s)" % (os.getpid(), os.getppid())) for i in range(q.qsize()): print("read进程 从 Queue 获取到消息：%s" % q.get(True)) def write(q): print("write进程 启动(%s),主进程为(%s)" % (os.getpid(), os.getppid())) for i in "Python": q.put(i) if __name__=="__main__": print("主进程(%s) start" % os.getpid()) q = Manager().Queue() # 使用 Manager 中的 Queue # 定义一个进程池 po = Pool() # Pool().apply_async(要调用的目标,(传递给目标的参数元祖,)) po.apply_async(write, (q,)) time.sleep(1) # 先让上面的任务向 Queue 存入数据，然后再让下面的任务开始从中取数据 po.apply_async(read, (q,)) po.close() # 关闭进程池，关闭后 po 不再接收新的请求 po.join() # 等待 po 中所有子进程执行完成，必须放在 close 语句之后 print("(%s) End!" % os.getpid()) 

import _thread import time import random # 为线程定义一个函数 def print_time(threadName): count = 0 while count <5: time.sleep(random.random()) count +=1 print ("%s: %s" % (threadname, time.ctime(time.time()))) # 创建两个线程 try: _thread.start_new_thread(print_time, ("thread-1",)) ("thread-2",)) except: ("error: 无法启动线程") while true: pass < pre>

# 使用 threading 模块创建线程 import threading import time import random class myThread(threading.Thread): def __init__(self, threadID, name): threading.Thread.__init__(self) self.threadID = threadID self.name = name self.delay = random.random() def run(self): print ("开始线程：" + self.name) print_time(self.name, 5) print ("退出线程：" + self.name) def print_time(threadName, count): while count: time.sleep(random.random()) print ("%s: %s" % (threadName, time.ctime(time.time()))) count -= 1 # 创建两个线程 thread1 = myThread(1, "Thread-1") thread2 = myThread(2, "Thread-2") # 开启新线程 thread1.start() thread2.start() thread1.join() thread2.join() print ("退出主线程") 

import asyncio import time import random async def work(msg): print("收到的信息:'{}'".format(msg)) print("{}1{}".format("*"*10,"*"*10)) # 为了方便，展示结果 await asyncio.sleep(random.random()) print("{}2{}".format("*"*10,"*"*10)) # 为了方便，展示结果 print(msg) async def main(): # 创建两个任务对象(协程)，并加入到事件循环中 Coroutines1 = asyncio.create_task(work("hello")) Coroutines2 = asyncio.create_task(work("Python")) print("开始时间: {}".format(time.asctime(time.localtime(time.time())))) await Coroutines1  # 此时并发运行Coroutines1和Coroutines2 print("{}3{}".format("*"*10,"*"*10)) # 为了方便，展示结果 await Coroutines2 # await相当于挂起当前任务，去执行其他任务，此时是堵塞的 print("{}4{}".format("*"*10,"*"*10)) # 为了方便，展示结果 print("结束时间:{}".format(time.asctime(time.localtime(time.time())))) asyncio.run(main())# asyncio.run(main())创建一个事件循环，并以main为主要程序入口