network.groovy

example.groovy

import java.util.concurrent.*

import java.util.concurrent.TimeUnit;
import java.util.UUID;
 
public class Task implements Runnable {
    public void run() {
        Socket s = new Socket(InetAddress.getByName("localhost"), 8081);
        try {
            Random rand  = new Random() 
        
            println "Opening connection to 8081"
            s.setKeepAlive(true)
            println "Setting socket to be alive"
            PrintWriter pw = new PrintWriter(s.getOutputStream());
            pw.println("GET /hello/world HTTP/1.1");
            pw.println("Host: localhost");
            pw.println("Connection: keep-alive")
            pw.println("X-Header: ${UUID.randomUUID().toString()}");
            pw.println("Content-Type: ${UUID.randomUUID().toString()}");
            pw.println("Agent: ${UUID.randomUUID().toString()}");
            pw.println("X-Header: ${UUID.randomUUID().toString()}");
            pw.println("Content-Type: ${UUID.randomUUID().toString()}");
            pw.println("Agent: ${UUID.randomUUID().toString()}");
            pw.println("X-Header: ${UUID.randomUUID().toString()}");
            pw.println("Content-Type: ${UUID.randomUUID().toString()}");
            pw.println("Agent: ${UUID.randomUUID().toString()}");
            pw.println("X-Header: ${UUID.randomUUID().toString()}");
            pw.println("Content-Type: ${UUID.randomUUID().toString()}");
            pw.println("Agent: ${UUID.randomUUID().toString()}");
            pw.println("");
            pw.flush();
            Thread.sleep(rand.nextInt(100000))
            println "Closing socket"
            s.close();
        } catch (InterruptedException e) {
            e.printStackTrace();
        } finally {
            println "Finished ..."
        }
    }
}


int THREAD_POOL_SIZE = 40000
ThreadPoolExecutor executor = (ThreadPoolExecutor) Executors.newFixedThreadPool(3000 );


(0..THREAD_POOL_SIZE).each {
    Task task = new Task()
    executor.execute(task);
}

executor.shutdown()