多进程

import time
import multiprocessing


def test1():
    while True:
        print("1.....")
        time.sleep(1)


def test2():
    while True:
        print("2....")
        time.sleep(1)


def main():
    p1 = multiprocessing.Process(target=test1)
    p2 = multiprocessing.Process(target=test2)
    p1.start()
    p2.start()


if __name__ == "__main__":
    main()

E:\python_project\NetWork\venv\Scripts\python.exe E:/python_project/NetWork/process/__init__.py
1.....
2....
1.....
2....
1.....
2....
1.....
2....
1.....
2....
1.....
2....
1.....
2....
1.....
2....
1.....
2....

Process finished with exit code -1

队列先进先出，与队列相反的是栈，先进后出

通过队列实现进程间通讯

import multiprocessing


def download_fromWeb(queue):
    # 从网上下载数据
    data = [11, 22, 33, 44]
    for temp in data:
        queue.put(temp)


def analysis_data(queue):
    # 从队列中取数据,放到list中
    waiting = list()
    while True:
        data = queue.get()
        waiting.append(data)
        if queue.empty():
            break
    print(waiting)


def main():
    # 创建一个队列
    queue = multiprocessing.Queue(6)

    # 创建多个进程将队列的引用传递到进程里面
    p1 = multiprocessing.Process(target=download_fromWeb, args=(queue,))
    p2 = multiprocessing.Process(target=analysis_data, args=(queue,))
    p1.start()
    p2.start()


if __name__ == "__main__":
    main()

E:\python_project\NetWork\venv\Scripts\python.exe E:/python_project/NetWork/process/Queue.py
[11, 22, 33, 44]

Process finished with exit code 0

进程池

from multiprocessing import Pool
import time, os, random


def worker(po):
    t_start = time.time()
    print("%s开始执行，进程号为%d" % (po, os.getpid()))


def main():
    # 定义一个进程池,最大进程数3
    po = Pool(3)
    for i in range(0, 10):
        # Pool().apply_async(要调用的目标，（传递给目标的参数元祖，）)
        # 每次循环将会用空闲出来的子进程去调用目标
        po.apply_async(worker, (i,))
    # 关闭进程池，关闭后po不再接收新的请求
    po.close()
    # 等待po中所有子进程执行完成，必须放在close之后
    po.join()


if __name__ == "__main__":
    main()

E:\python_project\NetWork\venv\Scripts\python.exe E:/python_project/NetWork/process/ProcessPool.py
0开始执行，进程号为10712
1开始执行，进程号为10712
2开始执行，进程号为10712
3开始执行，进程号为10712
4开始执行，进程号为10712
5开始执行，进程号为10712
6开始执行，进程号为10712
7开始执行，进程号为10712
8开始执行，进程号为10712
9开始执行，进程号为10712

Process finished with exit code 0