Java性能优化：从单线程执行到线程池管理的进阶实践

import java.util.concurrent.ExecutorService;  
import java.util.concurrent.Executors;  
  
public class ThreadPoolExample {  
  
    public static void main(String[] args) {  
        // 创建一个固定大小为5的线程池  
        ExecutorService executor = Executors.newFixedThreadPool(5);  
  
        // 模拟多个用户下单请求  
        for (int i = 0; i < 10; i++) {  
            final int orderId = i;  
            executor.submit(() -> {  
                // 执行后台任务，如库存更新、订单生成等  
                processOrder(orderId);  
            });  
        }  
  
        // 关闭线程池（注意：这里只是提交关闭请求，已提交的任务会继续执行）  
        executor.shutdown();  
          
        // 等待所有任务完成（可选）  
        while (!executor.isTerminated()) {  
            // 可以选择做一些其他事情，比如记录日志、更新状态等  
            // 这里简单使用Thread.sleep模拟等待  
            try {  
                Thread.sleep(100);  
            } catch (InterruptedException e) {  
                Thread.currentThread().interrupt();  
                // 处理中断逻辑  
            }  
        }  
  
        System.out.println("所有订单处理完成");  
    }  
  
    private static void processOrder(int orderId) {  
        // 模拟耗时任务  
        try {  
            Thread.sleep(1000); // 假设每个订单处理需要1秒  
        } catch (InterruptedException e) {  
            Thread.currentThread().interrupt();  
        }  
        System.out.println("订单ID：" + orderId + " 处理完成");  
    }  
}

// 实现Runnable接口  
public class MyRunnable implements Runnable {  
    @Override  
    public void run() {  
        // 线程执行的任务  
        System.out.println(Thread.currentThread().getName() + "正在执行");  
    }  
}  
  
// 创建并启动线程  
public class ThreadDemo {  
    public static void main(String[] args) {  
        Thread t1 = new Thread(new MyRunnable());  
        t1.start();  
          
        // Java 8以后，可以使用Lambda表达式简化  
        new Thread(() -> System.out.println(Thread.currentThread().getName() + "通过Lambda启动")).start();  
    }  
}

import java.util.concurrent.ExecutorService;  
import java.util.concurrent.Executors;  
  
public class ThreadPoolDemo {  
    public static void main(String[] args) {  
        // 创建固定大小的线程池  
        ExecutorService executor = Executors.newFixedThreadPool(5);  
  
        for (int i = 0; i < 10; i++) {  
            int taskId = i;  
            executor.execute(() -> {  
                System.out.println(Thread.currentThread().getName() + "正在执行任务 " + taskId);  
            });  
        }  
  
        // 关闭线程池，不再接受新任务，但已提交的任务会继续执行  
        executor.shutdown();  
    }  
}