dorkbox
/
Benchmarks
1
0
Fork 0
Code Issues Pull Requests Releases Wiki Activity

Added JCtools mpmc array queue test. Added missing libs. Added launch configs to idea.

master
nathan 2016-02-18 01:43:37 +01:00
parent 4cd39d1a2a
commit 46c6274437
6 changed files with 29 additions and 13 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

14
Benchmarks.iml
View File

@ -7,19 +7,7 @@
</content>
<orderEntry type="inheritedJdk" />
<orderEntry type="sourceFolder" forTests="false" />
<orderEntry type="module-library">
<library>
<CLASSES>
<root url="file://$MODULE_DIR$/libs" />
</CLASSES>
<JAVADOC />
<SOURCES>
<root url="file://$MODULE_DIR$/libs" />
</SOURCES>
<jarDirectory url="file://$MODULE_DIR$/libs" recursive="false" />
<jarDirectory url="file://$MODULE_DIR$/libs" recursive="false" type="SOURCES" />
</library>
</orderEntry>
<orderEntry type="library" name="libs" level="project" />
</component>
<component name="org.twodividedbyzero.idea.findbugs">
<option name="_basePreferences">

BIN
libs/jctools-core-1.1-sources.jar Normal file
View File

Binary file not shown.

BIN
libs/jctools-core-1.1.jar Normal file
View File

Binary file not shown.

BIN
libs/kryo-3.0.3-sources.zip Normal file
View File

Binary file not shown.

BIN
libs/kryo-3.0.3.jar Normal file
View File

Binary file not shown.

28
src/dorkbox/benchmark/Test_Queue_MpmcArrayQueue.java Normal file
View File

@ -0,0 +1,28 @@
package dorkbox.benchmark;
import dorkbox.benchmark.common.Base_BlockingQueue;
import dorkbox.benchmark.common.Base_Queue;
@SuppressWarnings("Duplicates")
public class Test_Queue_MpmcArrayQueue extends Base_BlockingQueue {
public static final int REPETITIONS = 50 * 1000 * 100;
private static final int bestRunsToAverage = 4;
private static final int runs = 10;
private static final int warmups = 3;
public static void main(final String[] args) throws Exception {
System.out.format("reps: %,d %s: \n", REPETITIONS, Test_Queue_MpmcArrayQueue.class.getSimpleName());
for (int concurrency = 1; concurrency < 5; concurrency++) {
final org.jctools.queues.MpmcArrayQueue queue = new org.jctools.queues.MpmcArrayQueue(1 << 17);
final Integer initialValue = Integer.valueOf(777);
new MpmcArray_NonBlock().run(REPETITIONS, concurrency, concurrency, warmups, runs, bestRunsToAverage, false, queue,
initialValue);
}
}
static
class MpmcArray_NonBlock extends Base_Queue<Integer> {}
}