import net.openhft.collections.NonBlockingQueue;
import net.openhft.collections.SharedNonBlockingHashMap;
import net.openhft.collections.SharedNonBlockingHashSet;
public class HighFrequencyTradingSystem {
public static void main(String[] args) {
NonBlockingQueue<Integer> queue = new SharedNonBlockingHashMap<>();
new Thread(() -> {
for (int i = 0; i < 10; i++) {
queue.add(i);
}
}).start();
new Thread(() -> {
while (true) {
Integer item = queue.poll();
if (item != null) {
}
}
}).start();
}
}
