!7

static Lock a = fairLock();
static Lock b = fairLock();

p-tt {
  centerHigherConsole();
  
  doEvery_daemon(1000, r {
    L<ThreadInfo> lockingThreads = printDeadlocks();
    if (nempty(lockingThreads)) {
      print("Interrupting locking threads.");
      L<Thread> threads = threadInfosToThreads(lockingThreads);
      if (nempty(threads)) {
        Thread t = random(threads);
        print("Interrupting thread " + quote(t.getName()));
        t.interrupt();
      }
    }
  });
  
  print("Initiating deadlock... :-)\n");
  
thread "A" {
    lock(a);
    try {
      print("Thread A has lock A.");
      sleep1Second();
      print("Thread A getting lock B.");
      lock(b);
      try {
        print("Thread A successful!");
      } finally {
        b.unlock();
      }
    } finally {
      a.unlock();
    }
  }
  
  thread "B" {
    lock(b);
    try {
      print("Thread B has lock B.");
      sleep1Second();
      print("Thread B getting lock A.");
      lock(a);
      try {
        print("Thread B successful!");
      } finally {
        a.unlock();
      }
    } finally {
      b.unlock();
    }
  }
 
  sleepQuietly();
}