java - 循环障碍Java，如何验证？

Question

我正在准备面试，只想准备一些基本的线程示例和结构，以便在必要时在我的白板编码中使用它们。

我正在阅读有关 CyclicBarrier 的文章，并且只是尝试一下，所以我写了一个非常简单的代码:

import java.util.concurrent.CyclicBarrier;

public class Threads
{

    /**
     * @param args
     */
    public static void main(String[] args)
    {
        // ******************************************************************
        // Using CyclicBarrier to make all threads wait at a point until all
        // threads reach there
        // ******************************************************************
        barrier = new CyclicBarrier(N);

        for (int i = 0; i < N; ++i)
        {
            new Thread(new CyclicBarrierWorker()).start();    
        }
        // ******************************************************************
    }

    static class CyclicBarrierWorker implements Runnable
    {
        public void run()
        {
          try
        {
            long id = Thread.currentThread().getId();
            System.out.println("I am thread " + id + " and I am waiting for my friends to arrive");

            // Do Something in the Thread
            Thread.sleep(1000*(int)(4*Math.random()*10));


            // Now Wait till all the thread reaches this point
            barrier.await();
        }
        catch (Exception e)
        {
            e.printStackTrace();
        }

        //Now do whatever else after all threads are released
        long id1 = Thread.currentThread().getId();
        System.out.println("Thread:"+id1+" We all got released ..hurray!!");
            System.out.println("We all got released ..hurray!!");
        }
    }

    final static int     N       = 4;
    static CyclicBarrier barrier = null;
}

您可以按原样复制粘贴并在您的编译器中运行。

我要验证的是代码中确实所有线程都在此时等待:

barrier.await();

我等了一会儿，希望我会看到 4 个语句以顺序方式在控制台上一个接一个地出现，然后是“已发布..hurray”语句的“爆发”。但无论我选择什么作为 sleep ，我都看到所有陈述一起爆发。

我是不是漏掉了什么？

谢谢P.S: 有没有像http://codepad.org/F01xIhLl这样的在线编辑器？我可以在哪里放置 Java 代码并点击一个按钮来运行一次性代码？ .我发现有些需要一些配置才能运行任何代码。

Answer 1

代码看起来不错，但在 sleep 前写入 System.out 可能更有启发性。在 run() 中考虑这个:

        long id = Thread.currentThread().getId();
        System.out.println("I am thread " + id + " and I am waiting for my friends to arrive");
        // Do Something in the Thread
        Thread.sleep(1000*8);

在我的机器上，我仍然看到一个爆裂，但很明显线程被阻塞在屏障上。