Python多线程&多进程&线程池&进程池

线程池

from threadpool import ThreadPool, makeRequests
import time
def x(many):
    for x in range(1, many):
        print(x)
        time.sleep(1)
p = ThreadPool(5)
requests = makeRequests(x, [5, 6, 10, 2])
for t in requests:
    p.putRequest(t, )
p.poll()  # 等待所有线程执行完成才能执行主线程
print('主线程')

多线程

from threading import Thread
import time


def x(many):
    for x in range(1, many):
        print(x)
        time.sleep(1)
thread_list = []
for i in range(1, 7):
    t = Thread(target=x, args=(i, ))
    thread_list.append(t)
for t in thread_list:
    t.setDaemon(True)  # 主线程执行完成后不管改线程是否完成都退出
    t.start()
    # t.join()  # 主线承等待该线程执行完成后才执行
print('主线程1')
time.sleep(1)
print('主线程2')

进程池

from multiprocessing.pool import Pool
import time

def x(many):
    for x in range(1, many):
        print("子进程%s - %s" % (many, x))
        time.sleep(1)
p = Pool(processes=5,)
for i in range(1, 20):
    p.apply_async(func=x, args=(i, ))
print('主进程')
p.close()
p.join()  # 等待所有子进程完成后主进程才能执行
print('主进程1')
time.sleep(3)
print('主进程2')

多进程

from multiprocessing import Process
import time
def x(many):
    for x in range(1, many):
        print("子进程%s - %s" % (many, x))
        time.sleep(1)
process_list = []
for i in range(1, 6):
    p = Process(target=x, args=(i,))
    process_list.append(p)
for p in process_list:
    p.daemon = True  # 主进程完成后即关闭该进程
    p.start()
    p.join()  # 主进程等待该进程结束后才执行
print('主进程1')
time.sleep(2)
print('主进程2')