Skip to content

Commit

Permalink
fix formatting
Browse files Browse the repository at this point in the history
  • Loading branch information
Edvard Fonsell committed Jan 24, 2020
1 parent 8c4d536 commit cecff74
Showing 1 changed file with 3 additions and 3 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -710,15 +710,15 @@ public void pollNextWorkflowInstancesWithPartialRaceCondition() throws Interrupt
dao.insertWorkflowInstance(instance);
}
Poller[] pollers = new Poller[] { new Poller(dao, batchSize), new Poller(dao, batchSize) };
for (int i=0; i<10; ++i) {
Thread[] threads = new Thread[]{new Thread(pollers[0]), new Thread(pollers[1])};
for (int i = 0; i < 10; ++i) {
Thread[] threads = new Thread[] { new Thread(pollers[0]), new Thread(pollers[1]) };
threads[0].start();
threads[1].start();
threads[0].join();
threads[1].join();
assertThat(pollers[0].returnSize + pollers[1].returnSize, is(batchSize));
if (pollers[0].detectedRaceCondition || pollers[1].detectedRaceCondition
|| (pollers[0].returnSize < batchSize && pollers[1].returnSize < batchSize)) {
|| (pollers[0].returnSize < batchSize && pollers[1].returnSize < batchSize)) {
return;
}
}
Expand Down

0 comments on commit cecff74

Please sign in to comment.