Search Results
OK to copy?
Examples 1 through 10 of
54 (0.073 seconds)
18
19
20 public class WorkerThread extends Thread
21 {
22 private static org.apache.commons.logging.Log log =
34 private String port;
35
36 public ServerThread(String database, String port) {
37 super("hsqldb-server");
38 this.database = database;
26 public class LagDetector extends Thread
27 {
28 private long incr = MAX_SLEEP / DIV;
29 private long totalLag;
30 private int count;
034 private Object control;
035 public static int MAX_NOTES=16;
036 private Object notes[]=new Object[MAX_NOTES];
037 private Hashtable attributes=new Hashtable();
038 private String currentStage;
027 */
028 public class Reaper extends Thread {
029 private boolean daemon = false;
030
031 public Reaper() {
096 private Socket socket;
097 private Jdk13ObjectReader reader;
098 private boolean keepRunning = true;
099 private static byte[] ackMsg = new byte[] {6,2,3};
100 ClusterListenThread(Socket socket, Jdk13ObjectReader reader) {
102 Runnable toRun;
103 public long runTime;
104 public SyncThread(Runnable toRun) {
105 this.toRun = toRun;
106 }
093 private Throwable ex;
094
095 public ConcurrencyTest(ITestBean proxy, Throwable ex) {
096 this.proxy = proxy;
097 this.ex = ex;