View Javadoc
1   /**
2    * Logback: the reliable, generic, fast and flexible logging framework.
3    * Copyright (C) 1999-2015, QOS.ch. All rights reserved.
4    *
5    * This program and the accompanying materials are dual-licensed under
6    * either the terms of the Eclipse Public License v1.0 as published by
7    * the Eclipse Foundation
8    *
9    *   or (per the licensee's choosing)
10   *
11   * under the terms of the GNU Lesser General Public License version 2.1
12   * as published by the Free Software Foundation.
13   */
14  package ch.qos.logback.core.contention;
15  
16  abstract public class AbstractMultiThreadedHarness {
17  
18      RunnableWithCounterAndDone[] runnableArray;
19  
20      abstract public void waitUntilEndCondition() throws InterruptedException;
21  
22      public void execute(RunnableWithCounterAndDone[] runnableArray) throws InterruptedException {
23          this.runnableArray = runnableArray;
24          Thread[] threadArray = new Thread[runnableArray.length];
25  
26          for (int i = 0; i < runnableArray.length; i++) {
27              threadArray[i] = new Thread(runnableArray[i], "Harness[" + i + "]");
28          }
29          for (Thread t : threadArray) {
30              t.start();
31          }
32  
33          waitUntilEndCondition();
34          for (RunnableWithCounterAndDone r : runnableArray) {
35              r.setDone(true);
36          }
37          for (Thread t : threadArray) {
38              t.join();
39          }
40      }
41  }