Java并发编程实战案例：如何使用多线程解决订单处理的问题？

原创 Myth丶恋晨 2024-10-15 09:00 47阅读 0赞

在Java中，我们可以使用多线程来并行处理订单。以下是一个简单的订单处理的多线程实现案例：

1. 创建订单类（Order.java）：
```java
public class Order {
    private String id;
    private String product;
    // getters and setters
}
```

2. 创建订单处理器类（OrderProcessor.java）：
```java
import java.util.ArrayList;
import java.util.List;

public class OrderProcessor {
    private List<Order> orders = new ArrayList<>();

// 添加订单到列表
    public void addOrder(Order order) {
        orders.add(order);
    }

// 处理订单，这里假设订单处理是一个耗时操作
    public synchronized void processOrders() throws InterruptedException {
        for (Order order : orders) {
            System.out.println("Processing Order: " + order.getId());
            // 模拟耗时操作
            Thread.sleep(500); // 5秒
        }
        System.out.println("Order processing completed.");
    }
}
```

3. 使用多线程处理订单（Main.java）：
```java
public class Main {
    public static void main(String[] args) {
        OrderProcessor processor = new OrderProcessor();

// 添加订单到处理器
        Order order1 = new Order();
        order1.setId("1");
        order1.product = "Product 1";
        processor.addOrder(order1);

Order order2 = new Order();
        order2.setId("2");
        order2.product = "Product 2";
        processor.addOrder(order2);

// 多线程处理订单
        Thread thread1 = new Thread(() -> {
            processor.processOrders();
            System.out.println("Thread 1 finished.");
        }));
        Thread thread2 = new Thread(() -> {
            processor.processOrders();
            System.out.println("Thread 2 finished.");
        }));

thread1.start();
        thread2.start();

// 等待所有线程完成
        try {
            thread1.join();
            thread2.join();
        } catch (InterruptedException e) {
            e.printStackTrace();
        }
    }
}
```

现在，当你运行`Main.java`时，订单处理会被两个线程并行执行。每个订单处理完成后，会输出一条消息表明该操作已完成。