使用Java处理并发问题的案例

原创傷城~ 2024-12-13 16:48 24阅读 0赞

在Java中，处理并发问题通常涉及以下几种方式：

1. **多线程**：直接创建多个线程来执行不同的任务。例如：

```java
class WorkerThread extends Thread {
    private String task;

public WorkerThread(String task) {
        this.task = task;
    }

@Override
    public void run() {
        // 执行任务
        System.out.println("WorkerThread running: " + task);
    }
}

public class ConcurrentExample {
    public static void main(String[] args) {
        // 创建工作线程
        WorkerThread worker1 = new WorkerThread("Task 1"));
        WorkerThread worker2 = new WorkerThread("Task 2");

// 启动工作线程
        worker1.start();
        worker2.start();

// 等待所有线程执行完毕
        worker1.join();
        worker2.join();
    }
}
```

2. **使用并发工具类**：Java提供了许多并发工具，如`ExecutorService`、`ThreadPoolExecutor`等。例如：

```java
import java.util.concurrent.Executors;
import java.util.concurrent.TimeUnit;

public class ExecutorServiceExample {
    public static void main(String[] args) {
        // 创建一个线程池
        ExecutorService executor = Executors.newFixedThreadPool(5);

// 提交任务到线程池
        for (int i = 0; i < 10; i++) {
            final int index = i;
            executor.submit(() -> {
                System.out.println("Task " + index + " is running.");
                try {
                    Thread.sleep(2000); // 模拟耗时操作
                } catch (InterruptedException e) {
                    e.printStackTrace();
                }
                System.out.println("Task " + index + " has finished.");
            });
        }

// 关闭线程池，释放资源
        executor.shutdown();
        try {
            if (!executor.isTerminated()) {
                System.err.println("Error: Some threads still running!");
            }
        } catch (InterruptedException e) {
            e.printStackTrace();
        }
    }
}
```

以上案例展示了如何使用多线程来处理并发问题。