Циклический барьер 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 оператора появляются один за другим впоследовательный способ на консоли, сопровождаемый 'взрывом' заявления "выпустили .. ура".Но я вижу взрыв всех утверждений вместе, независимо от того, что я выбираю в качестве сна.

Я что-то здесь упускаю?

Спасибо PS: есть ли такой онлайн-редактор, как http://codepad.org/F01xIhLl, где я могу просто поместить код Java и нажать кнопку, чтобы запустить выбрасываемый код?,Я нашел некоторые, которые требуют некоторой настройки, прежде чем я смогу запустить любой код.

Answer 1

, если вы хотите избежать первого всплеска, используйте случайное во сне

Thread.sleep(1000*(int)(8*Math.rand()));

Answer 2

Код выглядит хорошо, но было бы более поучительно написать в 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);

На моей машине я все еще вижу взрыв, но ясно, что нити на барьере заблокированы.

Answer 3

Я немного подождал и надеялся, что у меня на консоли последовательно и последовательно появятся 4 оператора, за которыми последует «взрыв» оператора «release..hurray».Но я вижу взрыв всех утверждений вместе, независимо от того, что я выбираю в качестве сна.

Наблюдаемое мной поведение заключается в том, что все созданные потоки спят примерно одинаковое количество времени.Помните, что другие потоки могут выполнять свою работу в промежутке, и поэтому будут запланированы;поскольку все созданные потоки спят в течение одинакового промежутка времени, между моментами вызова System.out.println очень мало различий.

Edit: другой ответ о спящемслучайное количество времени поможет лучше понять концепцию барьера, поскольку оно будет гарантировать (до некоторой степени) возможность попадания нескольких нитей в барьер в разные моменты времени.