Searched refs:runnable (Results 1 - 25 of 66) sorted by relevance

123

/forgerock/openam-v13/openam-shared/src/main/java/org/forgerock/openam/shared/concurrency/
H A DThreadMonitor.java40 * 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 DThreadMonitor.java41 * 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 DNonExpiringSessionManagerTest.java44 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 DSessionMaxStatsSetupListener.java54 private void inBackgroundThread(Runnable runnable) { argument
55 new Thread(runnable).start();
/forgerock/opendj-b2.6/src/server/org/opends/server/extensions/
H A DTLSByteChannel.java227 Runnable runnable;
228 while ((runnable = sslEngine.getDelegatedTask()) != null)
230 runnable.run();
/forgerock/opendj2/src/server/org/opends/server/extensions/
H A DTLSByteChannel.java226 Runnable runnable;
227 while ((runnable = sslEngine.getDelegatedTask()) != null)
229 runnable.run();
/forgerock/opendj2/src/guitools/org/opends/guitools/controlpanel/
H A DControlPanelLauncher.java354 Runnable runnable = new Runnable()
375 runnable.run();
381 SwingUtilities.invokeAndWait(runnable);
/forgerock/opendj-b2.6/src/guitools/org/opends/guitools/controlpanel/
H A DControlPanelLauncher.java352 Runnable runnable = new Runnable()
373 runnable.run();
379 SwingUtilities.invokeAndWait(runnable);
/forgerock/opendj2.6.2/src/server/org/opends/server/extensions/
H A DTLSByteChannel.java227 Runnable runnable;
228 while ((runnable = sslEngine.getDelegatedTask()) != null)
230 runnable.run();
/forgerock/opendj2.6.2/src/guitools/org/opends/guitools/controlpanel/
H A DControlPanelLauncher.java352 Runnable runnable = new Runnable()
373 runnable.run();
379 SwingUtilities.invokeAndWait(runnable);
/forgerock/opendj2-hg/src/guitools/org/opends/guitools/controlpanel/
H A DControlPanelLauncher.java354 Runnable runnable = new Runnable()
375 runnable.run();
381 SwingUtilities.invokeAndWait(runnable);
/forgerock/opendj2-jel-hg/src/guitools/org/opends/guitools/controlpanel/
H A DControlPanelLauncher.java352 Runnable runnable = new Runnable()
373 runnable.run();
379 SwingUtilities.invokeAndWait(runnable);
/forgerock/opendj2-jel-hg/src/server/org/opends/server/extensions/
H A DTLSByteChannel.java227 Runnable runnable;
228 while ((runnable = sslEngine.getDelegatedTask()) != null)
230 runnable.run();
/forgerock/opendj2-hg/src/server/org/opends/server/extensions/
H A DTLSByteChannel.java226 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 DControlPanelLauncher.java351 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 DTLSByteChannel.java217 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 DOperationStoreTest.java119 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 DOperationStoreTest.java119 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 DCachingRealmLookupTest.java83 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 DThreadMonitorTest.java115 * 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 DSessionMonitoringStoreTest.java225 public void execute(Runnable runnable) { argument
226 runnable.run();
/forgerock/openam-v13/openam-entitlements/src/test/java/org/forgerock/openam/entitlement/monitoring/
H A DPolicyMonitorImplTest.java167 public void execute(Runnable runnable) { argument
168 runnable.run();
/forgerock/openam/openam-shared/src/test/java/org/forgerock/openam/shared/concurrency/
H A DThreadMonitorTest.java128 * 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 DSessionMonitoringStoreTest.java225 public void execute(Runnable runnable) { argument
226 runnable.run();
/forgerock/openam/openam-entitlements/src/test/java/org/forgerock/openam/entitlement/monitoring/
H A DPolicyMonitorImplTest.java167 public void execute(Runnable runnable) { argument
168 runnable.run();

Completed in 171 milliseconds

123