代码复现：Java多线程同步问题实例

原创谁践踏了优雅 2024-09-15 15:33 49阅读 0赞

在Java中，多线程同步主要通过synchronized关键字、wait/notify机制以及java.util.concurrent包下的工具类来实现。

以下是一个简单的多线程同步问题实例：

```java
// 创建共享资源（可以是对象或变量）
public class SharedResource {
    private int count = 0;

// synchronized修饰的方法，确保同一时间只有一个线程执行这个方法
    public synchronized void increment() {
        count++;
    }

// 获取当前的共享资源计数
    public synchronized int getCount() {
        return count;
    }
}

// 创建两个线程
public class ThreadExample extends Thread {
    private SharedResource resource;

// 线程创建时，需要传入共享资源实例
    public ThreadExample(SharedResource resource) {
        this.resource = resource;
    }

@Override
    public void run() {
        try {
            // 同步调用方法，确保同一时间只有一个线程执行这个操作
            resource.increment();
            System.out.println("Thread " + this.getName() + " incremented count to: " + resource.getCount());

// 等待计数器达到某个值后继续执行（注意这里的wait是非阻塞的）
            if (resource.getCount() == 5) {
                resource.notifyAll(); // 唤醒所有等待的线程
            }
        } catch (InterruptedException e) {
            System.out.println("Thread " + this.getName() + " interrupted.");
            e.printStackTrace();
        }
    }
}

public class Main {
    public static void main(String[] args) {
        // 创建共享资源对象
        SharedResource resource = new SharedResource();

// 创建并启动两个线程
        ThreadExample thread1 = new ThreadExample(resource);
        ThreadExample thread2 = new ThreadExample(resource);

thread1.start(); // 启动第一个线程
        thread2.start(); // 启动第二个线程

// 这里不需要等待所有线程结束，因为我们的代码已经确保了同步。
    }
}
```

这个例子中，两个线程共享同一个资源（`SharedResource`）来进行计数。通过synchronized关键字确保了同一时间只有一个线程可以访问和修改资源。

如果线程A在执行increment()方法时被中断，那么当线程B再次尝试调用increment()时，由于资源已经被锁定，所以会抛出`InterruptedException`。