进程与线程的经典练习题

"""
1、用一个队列来存储数据

2、创建一个专门生产数据的任务函数，循环生产5次数据，每轮循环，往队列中添加20条数据，每循环一轮暂停1秒

3、创建一个专门处理数据的任务函数 循环获取队列中的数据处理，每秒处理4条数据。

4、创建一个线程(或进程)生产数据 ，3个线程(或进程)处理数据

5、统计数据生产并获取完  程序运行的总时长

"""
# ===============多线程实现============================
import time
from queue import Queue
from threading import Thread

q = Queue()


def add_data():
    """生产数据"""
    for i in range(5):
        for j in range(20):
            data = "数据--{}---{}".format(i, j)
            q.put(data)
            print("【生产数据】{}".format(data))
        time.sleep(1)


def handle_data():
    """处理数据"""
    while True:
        for i in range(4):
            try:
                data = q.get(timeout=1)
            except:
                return
            else:
                print("【处理数据】", data)
                q.task_done()
        time.sleep(1)

# def handle_data():
#     """处理数据"""
#     while not q.empty():
#         try:
#             data = q.get(timeout=1)
#         except:
#             return
#         else:
#             q.task_done()
#         time.sleep(0.25)


def main():
    """启动函数"""
    t1 = Thread(target=add_data)
    t1.start()
    for i in range(3):
        Thread(target=handle_data).start()
    # 等待数据生完
    t1.join()
    # 等待队列中的数据处理完
    q.join()


if __name__ == '__main__':
    st = time.time()
    main()
    et = time.time()
    print("程序运行总时长：", et - st)
"""
1、用一个队列来存储数据

2、创建一个专门生产数据的任务函数，循环生产5次数据，每轮循环，往队列中添加20条数据，每循环一轮暂停1秒

3、创建一个专门处理数据的任务函数 循环获取队列中的数据处理，每秒处理4条数据。

4、创建一个线程(或进程)生产数据 ，3个线程(或进程)处理数据

5、统计数据生产并获取完  程序运行的总时长

"""
# ===============多线程实现============================
import time
from queue import Queue
from threading import Thread

q = Queue()


def add_data():
    """生产数据"""
    for i in range(5):
        for j in range(20):
            data = "数据--{}---{}".format(i, j)
            q.put(data)
            print("【生产数据】{}".format(data))
        time.sleep(1)


def handle_data():
    """处理数据"""
    while True:
        for i in range(4):
            try:
                data = q.get(timeout=1)
            except:
                return
            else:
                print("【处理数据】", data)
                q.task_done()
        time.sleep(1)


def main():
    """启动函数"""
    t1 = Thread(target=add_data)
    t1.start()
    for i in range(3):
        Thread(target=handle_data).start()
    # 等待数据生完
    t1.join()
    # 等待队列中的数据处理完
    q.join()


if __name__ == '__main__':
    st = time.time()
    main()
    et = time.time()
    print("程序运行总时长：", et - st)