@Test public void wakeupNotExisting() { final ConstantTimeBackoff backoff = new ConstantTimeBackoff(); Assert.assertFalse(backoff.wakeup("NOT EXISTING THREAD")); }
@Override public boolean wakeup(final String threadName) { final Thread th = _asleep.get(threadName); if (th != null) { th.interrupt(); return true; } return false; }
ConstantTimeBackoff extends AdapterBase implements BackoffAlgorithm, ConstantTimeBackoffMBean { @Override public boolean wakeup(final String threadName) { final Thread th = _asleep.get(threadName); if (th != null) { th.interrupt(); return true; } return false; } }
ConstantTimeBackoff extends AdapterBase implements BackoffAlgorithm, ConstantTimeBackoffMBean { @Override public boolean wakeup(final String threadName) { final Thread th = _asleep.get(threadName); if (th != null) { th.interrupt(); return true; } return false; }  }
ConstantTimeBackoff extends AdapterBase implements BackoffAlgorithm, ConstantTimeBackoffMBean { @Override public boolean wakeup(final String threadName) { final Thread th = _asleep.get(threadName); if (th != null) { th.interrupt(); return true; } return false; }  @Override void waitBeforeRetry(); @Override void reset(); @Override boolean configure(final String name, final Map<String, Object> params); @Override long getTimeToWait(); @Override void setTimeToWait(final long seconds); @Override Collection<String> getWaiters(); @Override boolean wakeup(final String threadName); }
ConstantTimeBackoff extends AdapterBase implements BackoffAlgorithm, ConstantTimeBackoffMBean { @Override public boolean wakeup(final String threadName) { final Thread th = _asleep.get(threadName); if (th != null) { th.interrupt(); return true; } return false; }  @Override void waitBeforeRetry(); @Override void reset(); @Override boolean configure(final String name, final Map<String, Object> params); @Override long getTimeToWait(); @Override void setTimeToWait(final long seconds); @Override Collection<String> getWaiters(); @Override boolean wakeup(final String threadName);  }