import os 
from multiprocessing import Process
import time
def pro_func(name,age,**kwargs):
	print("進(jìn)程正在運(yùn)行,name=%s, age=%d, pid=%d" %(name, age, os.getpid()))
	print('kwargs參數(shù)值',kwargs)
	time.sleep(0.1)
if __name__=="__main__":
    p=Process(target=pro_func,args=('Friendship',18),kwargs={'愛(ài)好':'Python'})
    print('啟動(dòng)進(jìn)程')
    p.start()
    print('程是否還在活著:',p.is_alive())# 判斷進(jìn)程進(jìn)程是否還在活著
    time.sleep(0.5)
    # 1 秒鐘之后，立刻結(jié)束進(jìn)程
    print('結(jié)束進(jìn)程')
    p.terminate() # 不管任務(wù)是否完成，立即終止進(jìn)程
    p.join() # 等待子進(jìn)程執(zhí)行結(jié)束
    print('程是否還在活著:',p.is_alive())# 判斷進(jìn)程進(jìn)程是否還在活著

import os
import time
import random
from multiprocessing import Process,Queue
# 寫(xiě)數(shù)據(jù)函數(shù)
def write(q):
    for value in ['I','love','Python']:
        print('在隊(duì)列里寫(xiě)入 %s ' % value)
        q.put(value)
        time.sleep(random.random())
# 讀數(shù)據(jù)函數(shù)
def read(q):
    while True:
        if not q.empty():
            value  = q.get(True)
            print('從隊(duì)列中讀取 %s ' % value)
            time.sleep(random.random())
        else:
            break
if __name__=="__main__": # 主進(jìn)程
    # 主進(jìn)程創(chuàng)建 Queue，并傳給各個(gè)子進(jìn)程
    q=Queue()
    # 創(chuàng)建兩個(gè)進(jìn)程
    pw=Process(target=write,args=(q,))
    pr=Process(target=read,args=(q,))
    # 啟動(dòng)子進(jìn)程 pw
    pw.start()
    # 等待 pw結(jié)束
    pw.join()
    # 啟動(dòng)子進(jìn)程 pr
    pr.start()
    # 等待 pw結(jié)束
    pr.join()
    print('End!')

from multiprocessing import Manager,Pool
import os,time,random
def read(q):
    print("read進(jìn)程 啟動(dòng)(%s),主進(jìn)程為(%s)" % (os.getpid(), os.getppid()))
    for i in range(q.qsize()):
        print("read進(jìn)程 從 Queue 獲取到消息：%s" % q.get(True))
def write(q):
    print("write進(jìn)程 啟動(dòng)(%s),主進(jìn)程為(%s)" % (os.getpid(), os.getppid()))
    for i in "Python":
        q.put(i)
if __name__=="__main__":
    print("主進(jìn)程(%s) start" % os.getpid())
    q = Manager().Queue() # 使用 Manager 中的 Queue
    # 定義一個(gè)進(jìn)程池
    po = Pool()
    # Pool().apply_async(要調(diào)用的目標(biāo),(傳遞給目標(biāo)的參數(shù)元祖,))
    po.apply_async(write, (q,))
    time.sleep(1) # 先讓上面的任務(wù)向 Queue 存入數(shù)據(jù)，然后再讓下面的任務(wù)開(kāi)始從中取數(shù)據(jù)
    po.apply_async(read, (q,))
    po.close() # 關(guān)閉進(jìn)程池，關(guān)閉后 po 不再接收新的請(qǐng)求
    po.join() # 等待 po 中所有子進(jìn)程執(zhí)行完成，必須放在 close 語(yǔ)句之后
    print("(%s) End!" % os.getpid())

import _thread
import time
import random
# 為線(xiàn)程定義一個(gè)函數(shù)
def print_time(threadName):
    count = 0
    while count < 5:
        time.sleep(random.random())
        count += 1
        print ("%s: %s" % (threadName, time.ctime(time.time())))
# 創(chuàng)建兩個(gè)線(xiàn)程
try:
    _thread.start_new_thread(print_time, ("Thread-1",))
    _thread.start_new_thread(print_time, ("Thread-2",))
except:
    print ("Error: 無(wú)法啟動(dòng)線(xiàn)程")
while True:
	pass

# 使用 threading 模塊創(chuàng)建線(xiàn)程 
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 ("開(kāi)始線(xiàn)程：" + self.name)
        print_time(self.name, 5)
        print ("退出線(xiàn)程：" + self.name)
def print_time(threadName, count):
    while count:
        time.sleep(random.random())
        print ("%s: %s" % (threadName, time.ctime(time.time())))
        count -= 1
# 創(chuàng)建兩個(gè)線(xiàn)程
thread1 = myThread(1, "Thread-1")
thread2 = myThread(2, "Thread-2")
# 開(kāi)啟新線(xiàn)程
thread1.start()
thread2.start()
thread1.join()
thread2.join()
print ("退出主線(xiàn)程")

import asyncio
import time
import random
async def work(msg):
    print("收到的信息:'{}'".format(msg))
    print("{}1{}".format("*"*10,"*"*10)) # 為了方便，展示結(jié)果
    await asyncio.sleep(random.random())
    print("{}2{}".format("*"*10,"*"*10)) # 為了方便，展示結(jié)果
    print(msg)
async def main():
	# 創(chuàng)建兩個(gè)任務(wù)對(duì)象(協(xié)程)，并加入到事件循環(huán)中
    Coroutines1 = asyncio.create_task(work("hello"))
    Coroutines2 = asyncio.create_task(work("Python"))
    print("開(kāi)始時(shí)間: {}".format(time.asctime(time.localtime(time.time()))))
    await Coroutines1  # 此時(shí)并發(fā)運(yùn)行Coroutines1和Coroutines2
    print("{}3{}".format("*"*10,"*"*10)) # 為了方便，展示結(jié)果
    await Coroutines2 # await相當(dāng)于掛起當(dāng)前任務(wù)，去執(zhí)行其他任務(wù)，此時(shí)是堵塞的
    print("{}4{}".format("*"*10,"*"*10)) # 為了方便，展示結(jié)果
    print("結(jié)束時(shí)間:{}".format(time.asctime(time.localtime(time.time()))))
asyncio.run(main())# asyncio.run(main())創(chuàng)建一個(gè)事件循環(huán)，并以main為主要程序入口