Java多线程问题实例：同步与并发示例

原创 Bertha 。 2024-10-12 08:30 76阅读 0赞

在Java中，多线程通常涉及到同步机制来确保数据的一致性和正确性。以下是一个简单的例子，展示同步和并发的概念：

1. **线程同步**：
```java
// 创建一个共享变量count
public class Counter {
    private int count;

// 声明一个公共方法inc来增加计数器
    public synchronized void inc() {
        count++;
    }

// 获取当前的计数
    public synchronized int get() {
        return count;
    }
}

// 创建线程并调用共享资源
public class ThreadExample {
    public static void main(String[] args) {
        Counter counter = new Counter();

// 创建两个线程，一个增加计数器，另一个获取当前计数
        Thread threadIncrement = new Thread(() -> {
            while (true) {  // 无限循环
                if (!counter.inc()) {
                    break;  // 当计数器超过其最大值时跳出循环
                }
            }
        }));

Thread threadGetCount = new Thread(() -> {
            while (true) {  // 无限循环
                int count = counter.get();
                System.out.println("当前计数: " + count);
                if (count == 0) {  // 当计数器为零时跳出循环
                    break;
                }
            }
        }));

// 启动两个线程
        threadIncrement.start();
        threadGetCount.start();

// 等待两个线程完成任务后退出程序
        try {
            threadIncrement.join();
            threadGetCount.join();
        } catch (InterruptedException e) {
            e.printStackTrace();
        }
    }
}
```
2. **线程并发**：
```java
// 使用线程池来管理线程，提高资源利用率
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;

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

// 定义一组需要并发执行的任务
        List<Runnable> tasks = new ArrayList<>();
        for (int i = 0; i < 10; i++) {  // 创建10个任务
            tasks.add(() -> {
                System.out.println("Task " + i + " started...");
                try {
                    Thread.sleep(500);  // 模拟耗时操作
                } catch (InterruptedException e) {
                    e.printStackTrace();
                }
                System.out.println("Task " + i + " finished...");
            });
        }

// 执行任务列表
        for (Runnable task : tasks) {
            executor.execute(task);
        }

// 关闭线程池以释放资源
        executor.shutdown();

try {
            // 等待所有任务完成
            while (!executor.isTerminated())) {}
        } catch (InterruptedException e) {
            e.printStackTrace();
        }
    }
}
```
在这个例子中，线程同步用于确保`inc`方法的正确执行，即不会被其他线程干扰。而线程并发则是通过创建多个线程来同时执行任务，提高了程序的执行效率。