多线程编程：Java同步工具类使用示例

原创我会带着你远行 2024-10-19 17:27 53阅读 0赞

在Java中，我们通常会使用`synchronized`关键字或者一些同步工具类来实现多线程间的同步。

这里以常用的`java.util.concurrent.locks.ReentrantLock`为例，演示如何使用它进行同步：

```java
import java.util.concurrent.locks.ReentrantLock;

public class ThreadSyncExample {

private final ReentrantLock lock = new ReentrantLock();

public void threadA() {
        lock.lock();
        try {
            // 执行任务
            System.out.println("Task A is running by thread A.");
        } finally {
            lock.unlock(); // 无论是否发生异常，都需要解锁
            System.out.println("Unlocking lock in thread A.");
        }
    }

public void threadB() {
        lock.lock();
        try {
            // 执行任务
            System.out.println("Task B is running by thread B.");
        } finally {
            lock.unlock(); // 无论是否发生异常，都需要解锁
            System.out.println("Unlocking lock in thread B.");
        }
    }

public static void main(String[] args) {
        ThreadSyncExample example = new ThreadSyncExample();
        Thread threadA = new Thread(() -> example.threadA()));
        Thread threadB = new Thread(() -> example.threadB()));

threadA.start(); // 开始执行线程A
        threadB.start(); // 开始执行线程B

// 等待所有线程完成
        try {
            threadA.join(); // 线程A等待结束
            threadB.join(); // 线程B等待结束
        } catch (InterruptedException e) {
            e.printStackTrace();
        }
    }
}
```

在这个例子中，我们创建了两个线程`threadA`和`threadB`。每个线程都会获取一个互斥锁进行同步。

当主线程执行到`threadA.join()`或`threadB.join()`时，会使得对应的线程停止运行，直至其他线程全部完成才允许它们继续执行。

这样就实现了多线程间的同步。