同步器的代码示例

以下是第 80 项中提到的同步器的代码示例，并附有使用说明以方便学习：

1。 CountDownLatch：用于线程协调的一次性屏障
CountDownLatch 允许一个或多个线程等待，直到其他线程执行的一组操作完成。

import java.util.concurrent.CountDownLatch;

public class CountDownLatchExample {
    public static void main(String[] args) throws InterruptedException {
        int numberOfWorkers = 3;
        CountDownLatch latch = new CountDownLatch(numberOfWorkers);

        for (int i = 0; i 



<p><strong>2。信号量：控制对共享资源的访问</strong><br>
信号量管理一组权限来控制对有限资源的访问。<br>
</p>

<pre class="brush:php;toolbar:false">import java.util.concurrent.Semaphore;

public class SemaphoreExample {
    public static void main(String[] args) {
        int permits = 2; // Número de permissões disponíveis
        Semaphore semaphore = new Semaphore(permits);

        for (int i = 1; i 



<p><strong>3。 CyclicBarrier：可重用屏障点上的同步</strong><br>
CyclicBarrier 在公共点（屏障）同步多个线程。当所有线程到达屏障点后可以重复使用。<br>
</p>

<pre class="brush:php;toolbar:false">import java.util.concurrent.CyclicBarrier;

public class CyclicBarrierExample {
    public static void main(String[] args) {
        int numberOfThreads = 3;
        CyclicBarrier barrier = new CyclicBarrier(numberOfThreads, () -> {
            System.out.println("All threads have reached the barrier. Proceeding...");
        });

        for (int i = 0; i 



<p><strong>4。 Phaser：高级动态线程同步</strong><br>
Phaser 与 CyclicBarrier 类似，但支持动态进入和离开线程。<br>
</p>

<pre class="brush:php;toolbar:false">import java.util.concurrent.Phaser;

public class PhaserExample {
    public static void main(String[] args) {
        Phaser phaser = new Phaser(1); // Registra o "partida principal"

        for (int i = 0; i 



<p>这些示例可帮助您了解每个同步器的工作原理。您可以通过调整线程数量和计时来进行实验，观察对同步行为的影响。</p>


          

            
        

以上是同步器的代码示例的详细内容。更多信息请关注PHP中文网其他相关文章！