import org.hftcollections.concurrent.NonBlockingQueue;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
public class HFTCollectionsExample {
public static void main(String[] args) {
NonBlockingQueue<Integer> queue = new NonBlockingQueue<>();
ExecutorService executor = Executors.newFixedThreadPool(2);
executor.execute(() -> {
for (int i = 0; i < 100; i++) {
queue.offer(i);
}
});
executor.execute(() -> {
while (!queue.isEmpty()) {
Integer value = queue.poll();
System.out.println("Value: " + value);
}
});
executor.shutdown();
}
}
import org.hftcollections.io.mmap.MappedByteBuffer;
public class HFTCollectionsExample {
public static void main(String[] args) {
MappedByteBuffer buffer = new MappedByteBuffer("data.bin", 1024);
buffer.putInt(10);
buffer.putInt(20);
buffer.putInt(30);
int value1 = buffer.getInt(0);
int value2 = buffer.getInt(4);
int value3 = buffer.getInt(8);
System.out.println("Value1: " + value1);
System.out.println("Value2: " + value2);
System.out.println("Value3: " + value3);
buffer.close();
}
}
