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

原创ゝ一纸荒年。 2024-09-28 03:15 84阅读 0赞

在Java并发编程中，多线程同步是为了保证多个线程访问共享资源时不会发生冲突和数据不一致。以下是一个简单的Java并发编程实例，使用了`synchronized`关键字实现线程同步：

```java
public class SharedResource {
    private int count = 0;

// 同步方法，确保只有一个线程可以增加count
    public synchronized void incrementCount() {
        count++;
        System.out.println("Thread " + Thread.currentThread().getName() + " incremented count to " + count);
    }

// 同步方法，确保只有一个线程可以减少count（这里只是演示，实际情况需要处理边界和异常情况）。
    public synchronized void decrementCount() {
        count--;
        System.out.println("Thread " + Thread.currentThread().getName() + " decremented count to " + count);
    }
}

public class MultiThreadSynchronizationExample {
    public static void main(String[] args) {
        SharedResource resource = new SharedResource();

// 创建两个线程，分别增加和减少count
        Thread incrementThread = new Thread(() -> {
            for (int i = 0; i < 10; i++) {
                resource.incrementCount();
                try {
                    Thread.sleep(50); // 模拟耗时操作
                } catch (InterruptedException e) {
                    e.printStackTrace();
                }
            }
        }));

Thread decrementThread = new Thread(() -> {
            for (int i = 0; i < 10; i++) {
                resource.decrementCount();
                try {
                    Thread.sleep(50); // 模拟耗时操作
                } catch (InterruptedException e) {
                    e.printStackTrace();
                }
            }
        }));

incrementThread.start();
        decrementThread.start();

// 等待所有线程执行完毕
        while (!incrementThread.isFinished() || !decrementThread.isFinished())) {
            try {
                Thread.sleep(100); // 模拟等待时间
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
        }

System.out.println("Main thread finishing...");

resource = null; // 销毁资源引用

}
}
```

这个例子中，`SharedResource`类有两个同步方法`incrementCount()`和`decrementCount()`。这两个方法都使用了`synchronized`关键字，确保同一时间只有一个线程可以访问这些方法。

在`main`方法中，创建了两个线程分别增加和减少count。最后主线程等待所有线程执行完毕后结束程序。