同步器的代码示例

本篇文章向大家介绍《同步器的代码示例》，主要包括，具有一定的参考价值，需要的朋友可以参考一下。

本文提供四个Java并发同步器的代码示例及使用方法，帮助您理解Java多线程编程中的同步机制。

1. CountDownLatch：一次性屏障，协调线程

CountDownLatch允许一个或多个线程等待，直到其他线程完成一组操作。

import java.util.concurrent.Phaser;

public class PhaserExample {
    public static void main(String[] args) {
        Phaser phaser = new Phaser(1); // 注册“主方”

        for (int i = 0; i < 3; i++) {
            new Thread(() -> {
                System.out.println("Thread " + Thread.currentThread().getName() + " registered.");
                phaser.register(); // 注册线程
                try {
                    Thread.sleep(1000);
                    System.out.println("Thread " + Thread.currentThread().getName() + " arrived at phase " + phaser.getPhase());
                    phaser.arriveAndAwaitAdvance(); // 到达并等待其他线程
                    System.out.println("Thread " + Thread.currentThread().getName() + " passed phase " + phaser.getPhase());
                } catch (InterruptedException e) {
                    e.printStackTrace();
                } finally {
                    phaser.arriveAndDeregister(); // 完成并注销
                }
            }).start();
        }
        phaser.arriveAndAwaitAdvance(); // 主线程等待所有线程完成第一阶段
        System.out.println("All threads finished.");
    }
}

这些示例演示了每个同步器的基本用法。您可以修改线程数量和等待时间来观察同步行为的变化。 记住处理潜在的InterruptedException。

今天关于《同步器的代码示例》的内容就介绍到这里了，是不是学起来一目了然！想要了解更多关于的内容请关注golang学习网公众号！