Setting load factors

obsidiandynamics · Jul 18, 2019 · 4ee8afe · 4ee8afe
1 parent 651e601
commit 4ee8afe
Show file tree

Hide file tree

Showing 5 changed files with 7 additions and 7 deletions.
diff --git a/src/test/java/com/obsidiandynamics/indigo/EgressTest.java b/src/test/java/com/obsidiandynamics/indigo/EgressTest.java
@@ -44,7 +44,7 @@ public void testFunction_parallel() throws InterruptedException {
  }
 
  private void testFunction(int actors, int runs, boolean parallel) throws InterruptedException {
- final Set<ActorRef> doneRuns = new HashSet<>();
+ final Set<ActorRef> doneRuns = new HashSet<>(actors, 1f);
 
  system
  .addExecutor(EXECUTOR).named("custom")

diff --git a/src/test/java/com/obsidiandynamics/indigo/ParallelConsistencyTest.java b/src/test/java/com/obsidiandynamics/indigo/ParallelConsistencyTest.java
@@ -37,7 +37,7 @@ public void testFanInBiased() {
  }
 
  private void test(int actors, int runs, int fanIn, int sinkBias) {
- final Set<ActorRef> doneRuns = new HashSet<>();
+ final Set<ActorRef> doneRuns = new HashSet<>(actors * (fanIn + 1), 1f);
 
  new TestActorSystemConfig() {}
  .createActorSystem()

diff --git a/src/test/java/com/obsidiandynamics/indigo/RequestResponseBenchmark.java b/src/test/java/com/obsidiandynamics/indigo/RequestResponseBenchmark.java
@@ -101,7 +101,7 @@ private Summary test(Config c) {
  throw new IllegalArgumentException("Seed pairs cannot be greater than total number of pairs");
 
  final LogConfig log = c.log;
- final Set<DriverState> states = new HashSet<>();
+ final Set<DriverState> states = new HashSet<>(c.actors, 1f);
  final Summary summary = new Summary();
 
  if (log.stages) log.out.format("Warming up...\n");

diff --git a/src/test/java/com/obsidiandynamics/indigo/RequestResponseTest.java b/src/test/java/com/obsidiandynamics/indigo/RequestResponseTest.java
@@ -20,7 +20,7 @@ public final class RequestResponseTest implements IndigoTestSupport {
  public void testRequestResponse() {
  final int actors = 5;
  final int runs = 10;
- final Set<ActorRef> doneRuns = new HashSet<>();
+ final Set<ActorRef> doneRuns = new HashSet<>(actors, 1f);
 
  new TestActorSystemConfig() {}
  .createActorSystem()
@@ -46,7 +46,7 @@ public void testRequestResponse() {
 
  @Test
  public void testUnsolicitedReply_toSenderOf() {
- final Set<String> receivedRoles = new HashSet<>();
+ final Set<String> receivedRoles = new HashSet<>(2, 1f);
  new TestActorSystemConfig() {}
  .createActorSystem()
  .on(DRIVER).cue((a, m) -> {
@@ -68,7 +68,7 @@ public void testUnsolicitedReply_toSenderOf() {
 
  @Test
  public void testUnsolicitedReply_reply() {
- final Set<String> receivedRoles = new HashSet<>();
+ final Set<String> receivedRoles = new HashSet<>(1, 1f);
  new TestActorSystemConfig() {}
  .createActorSystem()
  .on(DRIVER).cue((a, m) -> {

diff --git a/src/test/java/com/obsidiandynamics/indigo/StatelessChainTest.java b/src/test/java/com/obsidiandynamics/indigo/StatelessChainTest.java
@@ -16,7 +16,7 @@ public final class StatelessChainTest implements IndigoTestSupport {
  public void test() {
  final int actors = 5;
  final int runs = 10;
- final Set<ActorRef> doneRuns = new HashSet<>();
+ final Set<ActorRef> doneRuns = new HashSet<>(actors, 1f);
 
  new TestActorSystemConfig() {}
  .createActorSystem()