/forgerock/openam-v13/openam-shared/src/main/java/org/forgerock/openam/shared/concurrency/ |
H A D | ThreadMonitor.java | 40 * rescheduled. This framework can also be used for standard runnable threads which 56 * The ThreadMonitor will use its own internal WatchDog class, itself runnable and a 100 * Triggers the given runnable to be executed immediately via the given ExecutorService. 102 * This will also generate a WatchDog thread to monitor the runnable and detect when it 105 * @param service Non null service which will hold the runnable. 106 * @param runnable Non null runnable to execute immediately. 108 public void watchThread(final ExecutorService service, final Runnable runnable) { argument 109 Reject.ifNull(service, runnable); 112 return service.submit(runnable); 136 watchScheduledThread(final ScheduledExecutorService scheduledService, final Runnable runnable, final long delay, final long duration, final TimeUnit timeUnit) argument [all...] |
/forgerock/openam/openam-shared/src/main/java/org/forgerock/openam/shared/concurrency/ |
H A D | ThreadMonitor.java | 41 * rescheduled. This framework can also be used for standard runnable threads which 64 * The ThreadMonitor will use its own internal WatchDog class, itself runnable and a 142 * Triggers the given runnable to be executed immediately via the given ExecutorService. 144 * This will also generate a WatchDog thread to monitor the runnable and detect when it 147 * @param service Non null service which will hold the runnable. 148 * @param runnable Non null runnable to execute immediately. 150 public void watchThread(final ExecutorService service, final Runnable runnable) { argument 151 Reject.ifNull(service, runnable); 154 return service.submit(runnable); 178 watchScheduledThread(final ScheduledExecutorService scheduledService, final Runnable runnable, final long delay, final long duration, final TimeUnit timeUnit) argument [all...] |
/forgerock/openam/openam-core/src/test/java/org/forgerock/openam/session/service/ |
H A D | NonExpiringSessionManagerTest.java | 44 private Runnable runnable; field in class:NonExpiringSessionManagerTest 58 runnable = (Runnable) invocationOnMock.getArguments()[1]; 72 verify(threadMonitor).watchScheduledThread(scheduledExecutorService, runnable, 0, 5, TimeUnit.MINUTES); 88 runnable.run();
|
/forgerock/openam/openam-core/src/main/java/com/iplanet/dpro/session/service/ |
H A D | SessionMaxStatsSetupListener.java | 54 private void inBackgroundThread(Runnable runnable) { argument 55 new Thread(runnable).start();
|
/forgerock/opendj-b2.6/src/server/org/opends/server/extensions/ |
H A D | TLSByteChannel.java | 227 Runnable runnable; 228 while ((runnable = sslEngine.getDelegatedTask()) != null) 230 runnable.run();
|
/forgerock/opendj2/src/server/org/opends/server/extensions/ |
H A D | TLSByteChannel.java | 226 Runnable runnable; 227 while ((runnable = sslEngine.getDelegatedTask()) != null) 229 runnable.run();
|
/forgerock/opendj2/src/guitools/org/opends/guitools/controlpanel/ |
H A D | ControlPanelLauncher.java | 354 Runnable runnable = new Runnable() 375 runnable.run(); 381 SwingUtilities.invokeAndWait(runnable);
|
/forgerock/opendj-b2.6/src/guitools/org/opends/guitools/controlpanel/ |
H A D | ControlPanelLauncher.java | 352 Runnable runnable = new Runnable() 373 runnable.run(); 379 SwingUtilities.invokeAndWait(runnable);
|
/forgerock/opendj2.6.2/src/server/org/opends/server/extensions/ |
H A D | TLSByteChannel.java | 227 Runnable runnable; 228 while ((runnable = sslEngine.getDelegatedTask()) != null) 230 runnable.run();
|
/forgerock/opendj2.6.2/src/guitools/org/opends/guitools/controlpanel/ |
H A D | ControlPanelLauncher.java | 352 Runnable runnable = new Runnable() 373 runnable.run(); 379 SwingUtilities.invokeAndWait(runnable);
|
/forgerock/opendj2-hg/src/guitools/org/opends/guitools/controlpanel/ |
H A D | ControlPanelLauncher.java | 354 Runnable runnable = new Runnable() 375 runnable.run(); 381 SwingUtilities.invokeAndWait(runnable);
|
/forgerock/opendj2-jel-hg/src/guitools/org/opends/guitools/controlpanel/ |
H A D | ControlPanelLauncher.java | 352 Runnable runnable = new Runnable() 373 runnable.run(); 379 SwingUtilities.invokeAndWait(runnable);
|
/forgerock/opendj2-jel-hg/src/server/org/opends/server/extensions/ |
H A D | TLSByteChannel.java | 227 Runnable runnable; 228 while ((runnable = sslEngine.getDelegatedTask()) != null) 230 runnable.run();
|
/forgerock/opendj2-hg/src/server/org/opends/server/extensions/ |
H A D | TLSByteChannel.java | 226 Runnable runnable; 227 while ((runnable = sslEngine.getDelegatedTask()) != null) 229 runnable.run();
|
/forgerock/opendj-v3/opendj-server-legacy/src/main/java/org/opends/guitools/controlpanel/ |
H A D | ControlPanelLauncher.java | 351 Runnable runnable = new Runnable() 373 runnable.run(); 379 SwingUtilities.invokeAndWait(runnable);
|
/forgerock/opendj-v3/opendj-server-legacy/src/main/java/org/opends/server/extensions/ |
H A D | TLSByteChannel.java | 217 Runnable runnable; 218 while ((runnable = sslEngine.getDelegatedTask()) != null) 220 runnable.run();
|
/forgerock/openam-v13/openam-core/src/test/java/org/forgerock/openam/cts/monitoring/impl/operations/ |
H A D | OperationStoreTest.java | 119 Runnable runnable = new Runnable() { 125 Thread t1 = new Thread(runnable); 127 Thread t2 = new Thread(runnable);
|
/forgerock/openam/openam-core/src/test/java/org/forgerock/openam/cts/monitoring/impl/operations/ |
H A D | OperationStoreTest.java | 119 Runnable runnable = new Runnable() { 125 Thread t1 = new Thread(runnable); 127 Thread t2 = new Thread(runnable);
|
/forgerock/openam/openam-core/src/test/java/org/forgerock/openam/core/realms/ |
H A D | CachingRealmLookupTest.java | 83 Runnable runnable = new Runnable() { 94 Thread t1 = new Thread(runnable, "Thread 1"); 95 Thread t2 = new Thread(runnable, "Thread 2");
|
/forgerock/openam-v13/openam-shared/src/test/java/org/forgerock/openam/shared/concurrency/ |
H A D | ThreadMonitorTest.java | 115 * Thread has had a chance to execute, therefore preventing execution of the runnable. 148 * Wire the runnable to trigger shutdown on ShutdownListener, which when 175 Runnable runnable = (Runnable) invocationOnMock.getArguments()[0]; 176 runnable.run();
|
/forgerock/openam-v13/openam-core/src/test/java/com/iplanet/dpro/session/monitoring/ |
H A D | SessionMonitoringStoreTest.java | 225 public void execute(Runnable runnable) { argument 226 runnable.run();
|
/forgerock/openam-v13/openam-entitlements/src/test/java/org/forgerock/openam/entitlement/monitoring/ |
H A D | PolicyMonitorImplTest.java | 167 public void execute(Runnable runnable) { argument 168 runnable.run();
|
/forgerock/openam/openam-shared/src/test/java/org/forgerock/openam/shared/concurrency/ |
H A D | ThreadMonitorTest.java | 128 * Thread has had a chance to execute, therefore preventing execution of the runnable. 161 * Wire the runnable to trigger shutdown on ShutdownListener, which when 229 Runnable runnable = (Runnable) invocationOnMock.getArguments()[0]; 230 runnable.run();
|
/forgerock/openam/openam-core/src/test/java/com/iplanet/dpro/session/monitoring/ |
H A D | SessionMonitoringStoreTest.java | 225 public void execute(Runnable runnable) { argument 226 runnable.run();
|
/forgerock/openam/openam-entitlements/src/test/java/org/forgerock/openam/entitlement/monitoring/ |
H A D | PolicyMonitorImplTest.java | 167 public void execute(Runnable runnable) { argument 168 runnable.run();
|