/* @test

 * @summary Performance test for rest adapter

 * @library /test/lib

 * @modules java.management.rest/com.oracle.jmx.remote.rest.http

 *          java.management.rest/com.oracle.jmx.remote.rest.json

 *          java.management.rest/com.oracle.jmx.remote.rest.json.parser

 *          java.management.rest/com.oracle.jmx.remote.rest.mapper

 * @build RestAdapterPerfTest RestAdapterTest

 * @run testng/othervm RestAdapterPerfTest

 */

import jdk.test.lib.Utils;

import java.util.List;

import java.util.Random;

import java.util.concurrent.Executors;

import java.util.concurrent.ThreadPoolExecutor;

import java.util.concurrent.TimeUnit;

import java.util.concurrent.atomic.AtomicInteger;

import org.testng.annotations.Test;

@Test

public class RestAdapterPerfTest {

    private static Random random = Utils.getRandomInstance();

    private static AtomicInteger count = new AtomicInteger(1);

    @Test

    public void testMultipleClients() throws Exception {

        RestAdapterTest test = new RestAdapterTest();

        ThreadPoolExecutor es = (ThreadPoolExecutor) Executors.newFixedThreadPool(20);

        es.setThreadFactory((Runnable R) -> new Thread(R, "perf-" + count.getAndIncrement()));

        long current = System.currentTimeMillis();

        test.setupServers();

        for (int i = 0; i < 200; i++) {

            Runnable task = tasks.get(random.nextInt(tasks.size()));

            es.execute(task);

        }

        System.out.println("Submitted 200 tasks");

        es.shutdown();

        es.awaitTermination(Long.MAX_VALUE, TimeUnit.SECONDS);

        float v = (float) (System.currentTimeMillis() - current) / (float) 1000;

        System.out.println("Total time = " + v + "s");

        test.tearDownServers();

    }

}