Commit 2667ccfc authored by Christian Wulf's avatar Christian Wulf

adapted to new TeeTime API

parent 8a944168
......@@ -27,10 +27,5 @@
<attribute name="maven.pomderived" value="true"/>
</attributes>
</classpathentry>
<classpathentry excluding="**" kind="src" output="target/test-classes" path="src/test/resources">
<attributes>
<attribute name="maven.pomderived" value="true"/>
</attributes>
</classpathentry>
<classpathentry kind="output" path="target/classes"/>
</classpath>
package teetime.benchmark.scheduler;
import java.util.*;
import java.util.ArrayList;
import java.util.List;
import java.util.concurrent.TimeUnit;
import java.util.stream.IntStream;
import org.openjdk.jmh.annotations.*;
import teetime.framework.*;
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 teetime.framework.scheduling.globaltaskpool.GlobalTaskPoolScheduling;
import teetime.stage.*;
import teetime.stage.BlackHoleStage;
import teetime.stage.CollectorSink;
import teetime.stage.StreamProducer;
@State(Scope.Benchmark)
@BenchmarkMode(Mode.SingleShotTime) // do not execute a benchmark method more than once per iteration
......@@ -65,7 +82,7 @@ public class GlobalTaskPoolBenchmark {
Configuration config = new Configuration().from(producer).to(blackHole0).to(blackHole1).to(blackHole2)
.end(sink);
TeeTimeService scheduling = new GlobalTaskPoolScheduling(numThreads, config, numExecutions);
TeeTimeScheduler scheduling = new GlobalTaskPoolScheduling(numThreads, config, numExecutions);
return new Execution<>(config, true, scheduling);
}
......
package teetime.benchmark.scheduler;
import java.util.*;
import java.util.ArrayList;
import java.util.List;
import java.util.concurrent.TimeUnit;
import java.util.stream.IntStream;
import org.openjdk.jmh.annotations.*;
import teetime.framework.*;
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 teetime.framework.scheduling.pushpullmodel.PushPullScheduling;
import teetime.stage.*;
import teetime.stage.BlackHoleStage;
import teetime.stage.CollectorSink;
import teetime.stage.StreamProducer;
@State(Scope.Benchmark)
@BenchmarkMode(Mode.SingleShotTime) // do not execute a benchmark method more than once per iteration
......@@ -65,7 +82,7 @@ public class PushPullBenchmark {
Configuration config = new Configuration().from(producer).to(blackHole0).to(blackHole1).to(blackHole2)
.end(sink);
TeeTimeService scheduling = new PushPullScheduling(config);
TeeTimeScheduler scheduling = new PushPullScheduling(config);
return new Execution<>(config, true, scheduling);
}
......
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