It is a low-latency Java concurrency library designed around ring buffers, sequencers, and customizable wait strategies. It provides both single-producer and multi-producer configurations, along with batch and single-item publishing modes, to maximize throughput and minimize contention
Build Environment requirements
- JDK 11 or greater
- Apache Maven 3.9.11 or greater
To build and run jmh tests execute the following commands:
mvn -pl jmh -am clean install
java -jar -Xms2G -Xmx2G -XX:+AlwaysPreTouch jmh/target/jmh-1.0-SNAPSHOT.jarIf you want to run with thread affinity execute the following command:
taskset -c <corerange> java -jar -Xms2G -Xmx2G -XX:+AlwaysPreTouch jmh/target/jmh-1.0-SNAPSHOT.jar To build and run jcstress tests execute the following commands:
mvn -pl jcstress -am clean install
java -jar -Xms2G -Xmx2G -XX:+AlwaysPreTouch jcstress/target/jcstress-1.0-SNAPSHOT.jar public class Main {
public static void main(String[] args) {
EventFactory<Event> factory = Event::new;
RingBuffer<Event> buffer = new RingBuffer<>(factory, SequencerType.SINGLE_PRODUCER, WaitPolicy.SPINNING, 1024);
EventHandler<Event> handler = new EventHandler<>() {
@Override
public void onEvent(Event event, long sequence) {
System.out.println("Event received: " + event + ", sequence: " + sequence);
}
@Override
public void onError(Throwable ex) {
}
@Override
public void onStart() {
}
@Override
public void onShutdown() {
}
};
EventTranslator.EventTranslatorOneArg<Event, Object> translator = Event::setEvent;
WorkerThread<Event> workerThread = new WorkerThread<>("test-worker", new ThreadGroup("thread-group"), buffer, WaitPolicy.PARKING, handler, BatchSizeLimit._1_2);
workerThread.start();
for (int i = 0; i < 1024; i++) {
buffer.publishEvent(translator, new Object());
}
}
public static class Event {
private Object event;
public Object getEvent() {
return event;
}
public void setEvent(Object event) {
this.event = event;
}
@Override
public String toString() {
return "Event{" + "event=" + event + '}';
}
}
}NAME="Fedora Linux"
VERSION="42 (KDE Plasma Desktop Edition)"
RELEASE_TYPE=stable
ID=fedora
VERSION_ID=42
VERSION_CODENAME=""
PLATFORM_ID="platform:f42"
PRETTY_NAME="Fedora Linux 42 (KDE Plasma Desktop Edition)"
CPE_NAME="cpe:/o:fedoraproject:fedora:42"
SUPPORT_END=2026-05-13
VARIANT="KDE Plasma Desktop Edition"
VARIANT_ID=kde
Architecture: x86_64
CPU op-mode(s): 32-bit, 64-bit
Address sizes: 48 bits physical, 48 bits virtual
Byte Order: Little Endian
CPU(s): 12
On-line CPU(s) list: 0-11
Vendor ID: AuthenticAMD
Model name: AMD Ryzen 9 5900X 12-Core Processor
CPU family: 25
Model: 33
Thread(s) per core: 1
Core(s) per socket: 12
Socket(s): 1
Stepping: 2
Frequency boost: disabled
CPU(s) scaling MHz: 61%
CPU max MHz: 6291.9360
CPU min MHz: 720.1620
BogoMIPS: 9399.78
Flags: fpu vme de pse tsc msr pae mce cx8 apic sep mtrr pge mca cmov pat pse36 clflush mmx fxsr sse sse2 ht syscall nx mmxext fxsr_opt pdpe1gb rdt
scp lm constant_tsc rep_good nopl xtopology nonstop_tsc cpuid extd_apicid aperfmperf rapl pni pclmulqdq monitor ssse3 fma cx16 sse4_1 sse4_
2 x2apic movbe popcnt aes xsave avx f16c rdrand lahf_lm cmp_legacy svm extapic cr8_legacy abm sse4a misalignsse 3dnowprefetch osvw ibs skin
it wdt tce topoext perfctr_core perfctr_nb bpext perfctr_llc mwaitx cat_l3 cdp_l3 hw_pstate ssbd mba ibrs ibpb stibp vmmcall fsgsbase bmi1
avx2 smep bmi2 erms invpcid cqm rdt_a rdseed adx smap clflushopt clwb sha_ni xsaveopt xsavec xgetbv1 xsaves cqm_llc cqm_occup_llc cqm_mbm_t
otal cqm_mbm_local user_shstk clzero irperf xsaveerptr rdpru wbnoinvd arat npt lbrv svm_lock nrip_save tsc_scale vmcb_clean flushbyasid dec
odeassists pausefilter pfthreshold avic v_vmsave_vmload vgif v_spec_ctrl umip pku ospke vaes vpclmulqdq rdpid overflow_recov succor smca fs
rm debug_swap
Virtualization features:
Virtualization: AMD-V
Caches (sum of all):
L1d: 384 KiB (12 instances)
L1i: 384 KiB (12 instances)
L2: 6 MiB (12 instances)
L3: 64 MiB (2 instances)
NUMA:
NUMA node(s): 1
NUMA node0 CPU(s): 0-11
Vulnerabilities:
Gather data sampling: Not affected
Ghostwrite: Not affected
Indirect target selection: Not affected
Itlb multihit: Not affected
L1tf: Not affected
Mds: Not affected
Meltdown: Not affected
Mmio stale data: Not affected
Reg file data sampling: Not affected
Retbleed: Not affected
Spec rstack overflow: Mitigation; Safe RET
Spec store bypass: Mitigation; Speculative Store Bypass disabled via prctl
Spectre v1: Mitigation; usercopy/swapgs barriers and __user pointer sanitization
Spectre v2: Mitigation; Retpolines; IBPB conditional; IBRS_FW; STIBP disabled; RSB filling; PBRSB-eIBRS Not affected; BHI Not affected
Srbds: Not affected
Tsa: Mitigation; Clear CPU buffers
Tsx async abort: Not affected
Results:
| Benchmark | Mode | Cnt | Score | Error | Units |
|---|---|---|---|---|---|
| ManyToOneRingBufferBatchPerfTest.manyToOne | thrpt | 5 | 667102846.752 | ± 14396123.676 | ops/s |
| ManyToOneRingBufferBatchPerfTest.manyToOne:producer1 | thrpt | 5 | 166785886.141 | ± 5733045.797 | ops/s |
| ManyToOneRingBufferBatchPerfTest.manyToOne:producer2 | thrpt | 5 | 166549133.081 | ± 3021114.988 | ops/s |
| ManyToOneRingBufferBatchPerfTest.manyToOne:producer3 | thrpt | 5 | 166982504.013 | ± 1830054.888 | ops/s |
| ManyToOneRingBufferBatchPerfTest.manyToOne:producer4 | thrpt | 5 | 166785323.517 | ± 4021763.914 | ops/s |
| ManyToOneRingBufferSingleItemPerfTest.manyToOne | thrpt | 5 | 38545375.262 | ± 66099.878 | ops/s |
| ManyToOneRingBufferSingleItemPerfTest.manyToOne:producer1 | thrpt | 5 | 9601547.399 | ± 95928.695 | ops/s |
| ManyToOneRingBufferSingleItemPerfTest.manyToOne:producer2 | thrpt | 5 | 9640775.695 | ± 196732.150 | ops/s |
| ManyToOneRingBufferSingleItemPerfTest.manyToOne:producer3 | thrpt | 5 | 9599867.147 | ± 321049.555 | ops/s |
| ManyToOneRingBufferSingleItemPerfTest.manyToOne:producer4 | thrpt | 5 | 9703185.020 | ± 9703185.020 | ops/s |
| OneToOneRingBufferBatchPerfTest.producer | thrpt | 5 | 413675970.602 | ± 1663507.408 | ops/s |
| OneToOneRingBufferSingleItemPerfTest.producer | thrpt | 5 | 195801682.174 | ± 347208.996 | ops/s |