# -*- coding: utf-8 -*-
from threading import Thread
from queue import Queue
import time

class ThreadPool:
    # 初始化
    def __init__(self, n):
        self.queue = Queue()
        for i in range(n):
            # 創(chuàng)建線程
            Thread(target=self.worker, daemon=True).start()		#daemon是開(kāi)啟守護(hù)線程

    # 執(zhí)行任務(wù)
    def worker(self):
        while True:
            func, args, kwargs = self.queue.get()
            func(*args, *kwargs)
            self.queue.task_done()

    # 獲取任務(wù)，將任務(wù)添加到隊(duì)列中
    def apply_async(self, target, args=(), kwargs={}):
        self.queue.put((target, args, kwargs))
    # 阻塞
    def join(self):
        self.queue.join()
def fun(x):
    print('愛(ài)孤寒者 第%s次' % x)
    time.sleep(3)
    print('帥哥美女就關(guān)注同名微信公眾號(hào)【孤寒者】啦~')

# 開(kāi)兩個(gè)線程
t = ThreadPool(2)
# 提交10個(gè)任務(wù)
for i in range(10):
    t.apply_async(fun, args=(i,))
t.join()

# -*- coding: utf-8 -*-
from multiprocessing.pool import ThreadPool
import time
pool = ThreadPool(2)  # 創(chuàng)建兩個(gè)線程
def funa(x, y):
    print('%s好好學(xué)習(xí)' % x)
    time.sleep(3)
    print('天天向上')
def funb(x, y):
    print('%shello' % x)
    time.sleep(3)
    print('world')

# 我們這就是有一個(gè)線程池，里面有兩個(gè)等待處理任務(wù)的線程，然后這兩個(gè)函數(shù)就是兩個(gè)任務(wù)，
# 線程池里一個(gè)線程處理一個(gè)，所以會(huì)同時(shí)輸出！如果多于兩個(gè)任務(wù)就會(huì)執(zhí)行等待sleep

pool.apply_async(funa, args=('我們要————', 2))  # 將任務(wù)添加到線程池
pool.apply_async(funb, args=('大家要————', 4))

pool.close()  # close之后則無(wú)法向線程池提交任務(wù)

# 內(nèi)置線程池，自帶守護(hù)線程，主線程結(jié)束，子線程也跟著結(jié)束
# 所以需要加阻塞，否則主線程一結(jié)束，子線程也跟著結(jié)束，無(wú)輸出
pool.join()  # 在join之前可使用終止線程，直接終止線程pool：  pool.terminate()

print('這是程序的最后一行，執(zhí)行到這里，主線程結(jié)束')