客服系统双12促销活动

import threading
import time

class OrderProcessor:
    def __init__(self):
        self.orders = []
        self.lock = threading.Lock()

    def add_order(self, order):
        with self.lock:
            self.orders.append(order)

    def process_orders(self):
        while True:
            with self.lock:
                if not self.orders:
                    break
                order = self.orders.pop(0)
            # 模拟订单处理时间
            time.sleep(0.1)
            print(f"Processed order {order}")

def main():
    processor = OrderProcessor()
    for i in range(100):
        processor.add_order(i)

    threads = []
    for _ in range(10):
        thread = threading.Thread(target=processor.process_orders)
        threads.append(thread)
        thread.start()

    for thread in threads:
        thread.join()

if __name__ == "__main__":
    main()