ThroughputServer.java

package org.microhttp;

import java.io.IOException;
import java.util.List;

public class ThroughputServer {

    public static void main(String[] args) throws IOException {
        Response response = new Response(
                200,
                "OK",
                List.of(new Header("Content-Type", "text/plain")),
                "hello world\n".getBytes());
        Options options = new Options()
                .withHost("0.0.0.0")
                .withConcurrency(args.length > 1 ? Integer.parseInt(args[1]) : Runtime.getRuntime().availableProcessors());
        Logger logger = new NoOpLogger();
        EventLoop eventLoop = new EventLoop(options, logger, (req, callback) -> callback.accept(response));
        eventLoop.start();
    }

    static class NoOpLogger implements Logger {
        @Override
        public boolean enabled() {
            return false;
        }

        @Override
        public void log(LogEntry... entries) {

        }

        @Override
        public void log(Exception e, LogEntry... entries) {

        }
    }

}