运行中难题：Java多线程同步问题实例

原创喜欢ヅ旅行 2024-09-22 16:09 75阅读 0赞

在Java多线程编程中，同步问题是常见的挑战。以下是一个具体的实例：

```java
// 创建两个共享资源的类
public class SharedResource {
    private int count = 0;

// 增加计数的方法，多个线程可以调用
    public synchronized void incrementCount() {
        count++;
        // 让调用incrementCount方法的线程知道资源已经更新
        notifyAll();
    }

// 获取当前计数值的方法，只能一个线程访问
    public synchronized int getCount() {
        return count;
    }
}

// 创建两个多线程类，共享同一个资源
public class ThreadExample {
    private SharedResource resource;

// 在构造函数中初始化共享资源
    public ThreadExample() {
        resource = new SharedResource();
    }

// 定义一个需要同步的线程方法
    public void threadTask(int incrementCount) {
        while (resource.getCount() < incrementCount) {
            try {
                // 获取锁，确保在操作资源时只有一个线程
                synchronized (resource) {
                    resource.incrementCount();  // 操作共享资源

// 如果资源已经达到预设条件，那么通知等待的线程
                    if (resource.getCount() >= incrementCount) {
                        notifyAll();
                    }
                }
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
        }
    }

public static void main(String[] args) {
        ThreadExample example = new ThreadExample();

// 创建两个线程，一个增加计数，另一个检查计数
        Thread thread1 = new Thread(() -> example.threadTask(5)));
        Thread thread2 = new Thread(() -> {
            try {
                int count = example.resource.getCount();
                if (count >= 5) {
                    System.out.println("Count is at least 5: " + count);
                } else {
                    System.out.println("Count is less than 5: " + count);
                }
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
        }));

// 启动线程
        thread1.start();
        thread2.start();

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

System.out.println("Shared resource update completed.");
    }
}
```

这个例子中，两个线程分别操作一个共享资源（增加计数和检查计数）。由于操作是同步的，所以不会出现数据不一致的问题。