Commit f7fefc59 authored by Christian Wulf's avatar Christian Wulf

updated to teetime 3.0

parent 2667ccfc
......@@ -34,7 +34,7 @@
<dependency>
<groupId>net.sourceforge.teetime</groupId>
<artifactId>teetime</artifactId>
<version>3.0-SNAPSHOT</version>
<version>3.0</version>
</dependency>
<dependency>
<groupId>ch.qos.logback</groupId>
......
package teetime.benchmark.scheduler;
import java.util.ArrayList;
import java.util.List;
import java.util.*;
import java.util.concurrent.TimeUnit;
import java.util.stream.IntStream;
import org.openjdk.jmh.annotations.Benchmark;
import org.openjdk.jmh.annotations.BenchmarkMode;
import org.openjdk.jmh.annotations.Fork;
import org.openjdk.jmh.annotations.Level;
import org.openjdk.jmh.annotations.Measurement;
import org.openjdk.jmh.annotations.Mode;
import org.openjdk.jmh.annotations.OutputTimeUnit;
import org.openjdk.jmh.annotations.Param;
import org.openjdk.jmh.annotations.Scope;
import org.openjdk.jmh.annotations.Setup;
import org.openjdk.jmh.annotations.State;
import org.openjdk.jmh.annotations.Warmup;
import teetime.framework.AbstractProducerStage;
import teetime.framework.Configuration;
import teetime.framework.Execution;
import teetime.framework.TeeTimeScheduler;
import org.openjdk.jmh.annotations.*;
import teetime.framework.*;
import teetime.framework.scheduling.globaltaskpool.GlobalTaskPoolScheduling;
import teetime.stage.BlackHoleStage;
import teetime.stage.CollectorSink;
import teetime.stage.StreamProducer;
import teetime.stage.*;
@State(Scope.Benchmark)
@BenchmarkMode(Mode.SingleShotTime) // do not execute a benchmark method more than once per iteration
......@@ -51,7 +34,10 @@ public class GlobalTaskPoolBenchmark {
private int numThreads;
@Param(value = { "64", "32", "2", "1" })
private int numExecutions;
@Param(value = { "2000000", "1000000", "1000" })
/**
* stage workload
*/
@Param(value = { "1000", "1000000", "2000000", })
private int numTokens;
private Execution<Configuration> execution;
......
package teetime.benchmark.scheduler;
import java.util.ArrayList;
import java.util.List;
import java.util.*;
import java.util.concurrent.TimeUnit;
import java.util.stream.IntStream;
import org.openjdk.jmh.annotations.Benchmark;
import org.openjdk.jmh.annotations.BenchmarkMode;
import org.openjdk.jmh.annotations.Fork;
import org.openjdk.jmh.annotations.Level;
import org.openjdk.jmh.annotations.Measurement;
import org.openjdk.jmh.annotations.Mode;
import org.openjdk.jmh.annotations.OutputTimeUnit;
import org.openjdk.jmh.annotations.Param;
import org.openjdk.jmh.annotations.Scope;
import org.openjdk.jmh.annotations.Setup;
import org.openjdk.jmh.annotations.State;
import org.openjdk.jmh.annotations.Warmup;
import teetime.framework.AbstractProducerStage;
import teetime.framework.Configuration;
import teetime.framework.Execution;
import teetime.framework.TeeTimeScheduler;
import org.openjdk.jmh.annotations.*;
import teetime.framework.*;
import teetime.framework.scheduling.pushpullmodel.PushPullScheduling;
import teetime.stage.BlackHoleStage;
import teetime.stage.CollectorSink;
import teetime.stage.StreamProducer;
import teetime.stage.*;
@State(Scope.Benchmark)
@BenchmarkMode(Mode.SingleShotTime) // do not execute a benchmark method more than once per iteration
......@@ -51,7 +34,10 @@ public class PushPullBenchmark {
private int numThreads;
// @Param(value = { "1", "2", "3", "4", "16", "31", "128", "256", "1024" })
// private int numExecutions;
@Param(value = { "0", "1000", "1000000", "10000000" })
/**
* stage workload
*/
@Param(value = { "1000", "1000000", "20000000" })
private int numTokens;
private Execution<Configuration> execution;
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment