Main.java

import java.util.concurrent.ArrayBlockingQueue;

public class Main {

    private static final boolean ENABLE_ANALYTICS = false;
    private static final boolean ENABLE_STORAGE   = false;

    public static void main(String[] args) throws InterruptedException {

        ArrayBlockingQueue<Order> queue = new ArrayBlockingQueue<>(200_000);

        MatchingEngine engine = new MatchingEngine(queue);

        if (ENABLE_ANALYTICS) {
            AnalyticsModule analytics = new AnalyticsModule();
            analytics.start();
            engine.setAnalytics(analytics);
        }
        if (ENABLE_STORAGE) {
            StorageLayer storage = new StorageLayer();
            storage.start();
            engine.setStorage(storage);
        }

        int total = 10_000_000;
        ProducerThread p1 = new ProducerThread(queue, "P1", total / 3);
        ProducerThread p2 = new ProducerThread(queue, "P2", total / 3);
        ProducerThread p3 = new ProducerThread(queue, "P3", total / 3);

        System.out.println(">>> STARTING 10M ORDER STRESS TEST...");
        long start = System.currentTimeMillis();

        engine.start();
        p1.start(); p2.start(); p3.start();

        p1.join(); p2.join(); p3.join();
        queue.put(Order.POISON_PILL);
        engine.join();

        long   end  = System.currentTimeMillis();
        double sec  = (end - start) / 1000.0;
        System.out.printf("%nTime: %.3fs | Throughput: %,.0f orders/sec%n",
            sec, total / sec);
    }
}