from multiprocessing import Process
import os
import time
 
def long_time_task(i):
    print('子進(jìn)程: {} - 任務(wù){(diào)}'.format(os.getpid(), i))
    time.sleep(2)
    print("結(jié)果: {}".format(8 ** 20))
 
if __name__=='__main__':
    print('當(dāng)前母進(jìn)程: {}'.format(os.getpid()))
    start = time.time()
    p1 = Process(target=long_time_task, args=(1,))
    p2 = Process(target=long_time_task, args=(2,))
    print('等待所有子進(jìn)程完成。')
    p1.start()
    p2.start()
    p1.join()
    p2.join()
    end = time.time()
    print("總共用時(shí){}秒".format((end - start)))

from multiprocessing import Pool, cpu_count
import os
import time
 
def long_time_task(i):
    print('子進(jìn)程: {} - 任務(wù){(diào)}'.format(os.getpid(), i))
    time.sleep(2)
    print("結(jié)果: {}".format(8 ** 20))
 
if __name__=='__main__':
    print("CPU內(nèi)核數(shù):{}".format(cpu_count()))
    print('當(dāng)前母進(jìn)程: {}'.format(os.getpid()))
    start = time.time()
    p = Pool(4)
    for i in range(5):
        p.apply_async(long_time_task, args=(i,))
    print('等待所有子進(jìn)程完成。')
    p.close()
    p.join()
    end = time.time()
    print("總共用時(shí){}秒".format((end - start)))

from multiprocessing import Process, Queue
import os, time, random
 
# 寫(xiě)數(shù)據(jù)進(jìn)程執(zhí)行的代碼:
def write(q):
    print('Process to write: {}'.format(os.getpid()))
    for value in ['A', 'B', 'C']:
        print('Put %s to queue...' % value)
        q.put(value)
        time.sleep(random.random())
 
# 讀數(shù)據(jù)進(jìn)程執(zhí)行的代碼:
def read(q):
    print('Process to read:{}'.format(os.getpid()))
    while True:
        value = q.get(True)
        print('Get %s from queue.' % value)
 
if __name__=='__main__':
    # 父進(jìn)程創(chuàng)建Queue，并傳給各個(gè)子進(jìn)程：
    q = Queue()
    pw = Process(target=write, args=(q,))
    pr = Process(target=read, args=(q,))
    # 啟動(dòng)子進(jìn)程pw，寫(xiě)入:
    pw.start()
    # 啟動(dòng)子進(jìn)程pr，讀取:
    pr.start()
    # 等待pw結(jié)束:
    pw.join()
    # pr進(jìn)程里是死循環(huán)，無(wú)法等待其結(jié)束，只能強(qiáng)行終止:
    pr.terminate()

import threading
import time
 
def long_time_task(i):
    print('當(dāng)前子線程: {} 任務(wù){(diào)}'.format(threading.current_thread().name, i))
    time.sleep(2)
    print("結(jié)果: {}".format(8 ** 20))
 
if __name__=='__main__':
    start = time.time()
    print('這是主線程：{}'.format(threading.current_thread().name))
    thread_list = []
    for i in range(1, 3):
        t = threading.Thread(target=long_time_task, args=(i, ))
        thread_list.append(t)
    for t in thread_list:
        t.start()
    for t in thread_list:
        t.join()
    end = time.time()
    print("總共用時(shí){}秒".format((end - start)))

import threading
 
class Account:
    def __init__(self):
        self.balance = 0
 
    def add(self, lock):
        # 獲得鎖
        lock.acquire()
        for i in range(0, 100000):
            self.balance += 1
        # 釋放鎖
        lock.release()
 
    def delete(self, lock):
        # 獲得鎖
        lock.acquire()
        for i in range(0, 100000):
            self.balance -= 1
            # 釋放鎖
        lock.release()
 
if __name__ == "__main__":
    account = Account()
    lock = threading.Lock()
    # 創(chuàng)建線程
   thread_add = threading.Thread(target=account.add, args=(lock,), name='Add')
    thread_delete = threading.Thread(target=account.delete, args=(lock,), name='Delete')
 
    # 啟動(dòng)線程
   thread_add.start()
    thread_delete.start()
 
    # 等待線程結(jié)束
   thread_add.join()
    thread_delete.join()
 
    print('The final balance is: {}'.format(account.balance))

from queue import Queue
import random, threading, time
 
# 生產(chǎn)者類(lèi)
class Producer(threading.Thread):
    def __init__(self, name, queue):
        threading.Thread.__init__(self, name=name)
        self.queue = queue
 
    def run(self):
        for i in range(1, 5):
            print("{} is producing {} to the queue!".format(self.getName(), i))
            self.queue.put(i)
            time.sleep(random.randrange(10) / 5)
        print("%s finished!" % self.getName())
 
# 消費(fèi)者類(lèi)
class Consumer(threading.Thread):
    def __init__(self, name, queue):
        threading.Thread.__init__(self, name=name)
        self.queue = queue
 
    def run(self):
        for i in range(1, 5):
            val = self.queue.get()
            print("{} is consuming {} in the queue.".format(self.getName(), val))
            time.sleep(random.randrange(10))
        print("%s finished!" % self.getName())
 
def main():
    queue = Queue()
    producer = Producer('Producer', queue)
    consumer = Consumer('Consumer', queue)
 
    producer.start()
    consumer.start()
 
    producer.join()
    consumer.join()
    print('All threads finished!')
 
if __name__ == '__main__':
    main()