import os
from multiprocessing import Process
def run\_proc(name):
    print('開始執(zhí)行子進(jìn)程 %s (%s)…' % (name, os.getpid()))
# 子進(jìn)程要執(zhí)行的代碼
if __name__ == '\_\_main\_\_':
    print('父進(jìn)程 %s.' % os.getpid())
    p = Process(target=run_proc, args=('test',)) # 創(chuàng)建一個(gè)Process實(shí)例
    print('子進(jìn)程即將開始.')
    p.start()  # 用start()方法啟動(dòng)實(shí)例
    p.join()   # join()方法可以等待子進(jìn)程結(jié)束后再繼續(xù)往下運(yùn)行，通常用于進(jìn)程間的同步
    print('子進(jìn)程結(jié)束.')

from multiprocessing import Pool
import os
import time
import random
def long\_time\_task(name):
    print('開始 task %s (%s)...' % (name, os.getpid()))
    start = time.time()
    time.sleep(random.random() * 3)
    end = time.time()
    print('Task %s 執(zhí)行花費(fèi) %0.2f 秒.' % (name, (end - start)))
if __name__ == '\_\_main\_\_':
    print('父親進(jìn)程 %s.' % os.getpid())
    p = Pool(3)
    # 因?yàn)镻ool的默認(rèn)大小是4,故task 0，1，2，3是立刻執(zhí)行的，而task 4要等待前面某個(gè)task完成后才執(zhí)行，但最多同時(shí)執(zhí)行4個(gè)進(jìn)程
    # 由于Pool的默認(rèn)大小是CPU的核數(shù)，如果你擁有8核CPU，要提交至少9個(gè)子進(jìn)程才能看到等待效果
    for i in range(5):
        p.apply_async(long_time_task, args=(i,))
    print('等待子進(jìn)程結(jié)束...')
    p.close()
    # 對(duì)Pool對(duì)象調(diào)用join()方法會(huì)等待所有子進(jìn)程執(zhí)行完畢
    # 調(diào)用join()之前必須先調(diào)用close()，調(diào)用close()之后就不能繼續(xù)添加新的Process了
    p.join()
    print('所有子進(jìn)程已執(zhí)行.')

import time
import threading
# 新線程執(zhí)行的代碼
def loop():
    # 由于任何進(jìn)程默認(rèn)就會(huì)啟動(dòng)一個(gè)線程，我們把該線程稱為主線程，主線程又可以啟動(dòng)新的線程，
    # Python的threading模塊有個(gè)current\_thread()函數(shù)，它永遠(yuǎn)返回當(dāng)前線程的實(shí)例
    print('線程ss %s 運(yùn)行中…' % threading.current_thread().name)
    n = 0
    # 主線程實(shí)例的名字叫MainThread,子線程的名字在創(chuàng)建時(shí)指定，我們用LoopThread命名子線程，在打印輸出的時(shí)候顯示名字
    while n < 5:
    n = n + 1
    print('線程ss %s >>> %s' % (threading.current_thread().name, n))
    time.sleep(1)
print('線程ss %s 已結(jié)束.' % threading.current_thread().name)
print('線程 %s is 運(yùn)行中…' % threading.current_thread().name)
t = threading.Thread(target=loop, name='LoopThread')
t.start()
t.join()
'''
對(duì)于 join()方法而言，其另一個(gè)重要方面是其實(shí)它根本不需要調(diào)用。
一旦線程啟動(dòng)，它們 就會(huì)一直執(zhí)行，直到給定的函數(shù)完成后退出。
如果主線程還有其他事情要去做，而不是等待這些線程完成(例如其他處理或者等待新的客戶端請(qǐng)求)，
就可以不調(diào)用 join()。join()方法只有在你需要等待線程完成的時(shí)候才是有用的
'''
print('線程 %s 已結(jié)束.' % threading.current_thread().name)