import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStreamReader;
import java.net.MalformedURLException;
import java.net.URL;
import java.util.concurrent.BrokenBarrierException;
import java.util.concurrent.CyclicBarrier;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
import java.util.concurrent.TimeUnit;
import java.util.logging.Level;
import java.util.logging.Logger;


public class HTTPClientCyclicBarrier implements Runnable {

    private static int TOTAL = 20;
    private static int COUNT = 10; //  количество запросов которые мы будем запускать одновременно.
    
    private static ExecutorService executorService = Executors.newFixedThreadPool(COUNT);
    private static CyclicBarrier  cyclicBarrier = new CyclicBarrier(COUNT);
    
    
    interface Lambda {

        void apply();
    }
    
    @Override
    public void run() {
        try {
            System.out.println("WAIT...");
             cyclicBarrier.await();
             System.out.println("LOADING...");
             test();
              System.out.println("FINISH");
        } catch (InterruptedException ex) {
            Logger.getLogger(HTTPClientCyclicBarrier.class.getName()).log(Level.SEVERE, null, ex);
        } catch (BrokenBarrierException ex) {
            Logger.getLogger(HTTPClientCyclicBarrier.class.getName()).log(Level.SEVERE, null, ex);
        }
       
    }



   static  long timeIt(Lambda lambda) {
        long start = System.nanoTime();
        lambda.apply();
        long end = System.nanoTime();
        long result = end - start;
        System.out.println("Time spent: " + (result) / 1000000000d + " sec\n");
        return result;
    }

    private void simpleClient() throws MalformedURLException, IOException, InterruptedException, BrokenBarrierException {
       
        URL url = new URL("http://www.yandex.ru/");
        BufferedReader in = new BufferedReader(new InputStreamReader(url.openStream()));
        String inputLine;
        while ((inputLine = in.readLine()) != null) {
            String s = inputLine;
        }
    }

    private void test() {
        timeIt(new Lambda() {
            @Override
            public void apply() {
                try {
                    simpleClient();
                } catch (Exception e) {
                    System.out.println(e);
                }

            }
        });
    }

    public static void main(String[] args) throws MalformedURLException, IOException, InterruptedException {
        for (int i = 0; i < TOTAL; i++) {
               HTTPClientCyclicBarrier barrier = new HTTPClientCyclicBarrier();
               executorService.submit(barrier);
        }
            
        executorService.awaitTermination(2L, TimeUnit.SECONDS);
        executorService.shutdown();
        
    }
}