从简单到复杂的Java并发编程案例

原创妖狐艹你老母 2024-12-05 13:18 13阅读 0赞

Java并发编程是一个广泛且深入的话题，涉及到线程、锁、条件变量、异步IO等多种机制。以下我将为你提供几个从简单到复杂的不同类型的Java并发编程案例：

1. **单线程**：
```java
public class SimpleThread {
    public void start() {
        // 这里是线程要执行的代码
        System.out.println("Hello from a simple thread.");
    }
}
```
2. **多线程竞争资源**（使用同步）：
```java
import java.util.concurrent.locks.Lock;
import java.util.concurrent.locks.ReentrantLock;

public class LockDemo {
    private final Lock lock = new ReentrantLock();

public void printMessage() throws InterruptedException {
        lock.lock();
        try {
            System.out.println("Worker thread printing message.");
        } finally {
            lock.unlock(); // 无论是否需要打印，都需要释放锁
        }
    }
}
```
3. **使用线程池**（提高并发效率）：
```java
import java.util.concurrent.Executors;
import java.util.concurrent.TimeUnit;

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

for (int i = 0; i < 10; i++) { // 模拟任务
            final int taskIndex = i;
            executor.execute(() -> {
                System.out.println("Task " + taskIndex + " is being executed.");
                // 这里是你需要执行的代码，可以是耗时操作等
            });
        }

// 关闭线程池
        executor.shutdown();
        try {
            // 等待所有任务完成
            if (!executor.awaitTermination(60, TimeUnit.SECONDS))) {
                System.err.println("Executor did not terminate within 60 seconds.");
            }
        } catch (InterruptedException e) {
            System.err.println("Interrupted while waiting for executor termination: " + e.getMessage());
            e.printStackTrace();
        }
    }
}
```
以上案例涵盖了Java并发编程中的基础线程、同步锁控制、线程池以及常见并发问题等。