1 9 package org.ozoneDB.core; 10 11 12 public class DeadlockThread extends Thread { 13 14 protected TransactionManager tm; 15 16 protected long sleepTime; 17 18 private volatile boolean stopRunning; 19 20 public DeadlockThread( long _sleepTime, TransactionManager _tm ) { 21 sleepTime = _sleepTime; 22 tm = _tm; 23 } 24 25 public final void stopRunning() { 26 stopRunning = true; 27 28 31 interrupt(); 32 } 33 34 35 public void run() { 36 for (stopRunning = false; !stopRunning; ) { 37 tm.checkDeadlocks(); 38 try { 39 sleep(sleepTime); 40 } catch (InterruptedException ignore) { 41 } 42 } 43 } 44 } 45 | Popular Tags |