Package eu.mosaic_cloud.benchmarks.prototype.Pipeline

Examples of eu.mosaic_cloud.benchmarks.prototype.Pipeline.BlockingQueueBuilder

31
32
33
34
35
36
37
38
39
40
41
    final int fanout = arguments.fanout;
    final long timeout = (long) (arguments.timeout * 1000);
    final Pipeline pipeline;
    final LinkedList<Unit.StatisticsReducer> reducers;
    {
      final BlockingQueueBuilder queueBuilder = new Pipeline.ArrayBlockingQueueBuilder (buffer, false);
      final Unit.UnitBuilder unitBuilder = new Unit.DefaultUnitBuilder ();
      final Unit.DefaultReducerBuilder<Unit.StatisticsReducer> reducerBuilder = new Unit.DefaultReducerBuilder<Unit.StatisticsReducer> (Unit.StatisticsReducer.class);
      reducers = reducerBuilder.reducers;
      pipeline = Pipeline.create (queueBuilder, fanout, queueBuilder, fanout, stages, (stages > 0) ? queueBuilder : null, (stages > 0) ? fanout : 0, unitBuilder, reducerBuilder);
    }
View Full Code Here
86
87
88
89
90
91
92
93
94
95
96
  }
 
  public final void warmPipeline ()
      throws InterruptedException
  {
    final BlockingQueueBuilder queueBuilder = new Pipeline.ArrayBlockingQueueBuilder (8, false);
    final Unit.UnitBuilder unitBuilder = new Unit.DefaultUnitBuilder ();
    for (int index = 0; index < 6; index++) {
      final Pipeline pipeline = Pipeline.create (queueBuilder, 8, queueBuilder, 8, 8, queueBuilder, 8, unitBuilder, null);
      pipeline.start ();
      Thread.sleep (1000);
View Full Code Here
TOP

Related Classes of eu.mosaic_cloud.benchmarks.prototype.Pipeline.BlockingQueueBuilder

  • eu.mosaic_cloud.benchmarks.prototype.Main
    • Copyright © 2018 www.massapicom. All rights reserved.
    All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.