Searched refs:executorService (Results 1 - 25 of 27) sorted by relevance

12

/forgerock/openam-v13/openam-core/src/main/java/com/iplanet/dpro/session/monitoring/
H A DSessionMonitoringStore.java44 private final ExecutorService executorService; field in class:SessionMonitoringStore
52 * @param executorService the service to which to offload out writes
55 public SessionMonitoringStore(@Named(EXECUTOR_BINDING_NAME) ExecutorService executorService, argument
57 this.executorService = executorService;
69 * @param executorService Service to perform writes with
76 SessionMonitoringStore(ExecutorService executorService, argument
82 this.executorService = executorService;
98 executorService
[all...]
/forgerock/openam-v13/openam-scripting/src/main/java/org/forgerock/openam/scripting/
H A DThreadPoolScriptEvaluator.java129 private final ExecutorService executorService; field in class:ThreadPoolScriptEvaluator.ThreadPoolConfigurator
131 ThreadPoolConfigurator(final ExecutorService executorService) { argument
132 this.executorService = executorService;
138 ExecutorServiceConfigurator delegateConfigurator = getDelegateConfigurator(executorService);
152 executorService)
185 private ExecutorServiceConfigurator getDelegateConfigurator(ExecutorService executorService) { argument
187 if (executorService instanceof ThreadPoolExecutor) {
188 return new ExecutorServiceConfigurator((ThreadPoolExecutor) executorService);
190 } else if (executorService instanceo
[all...]
/forgerock/openam/openam-scripting/src/main/java/org/forgerock/openam/scripting/
H A DThreadPoolScriptEvaluator.java129 private final ExecutorService executorService; field in class:ThreadPoolScriptEvaluator.ThreadPoolConfigurator
131 ThreadPoolConfigurator(final ExecutorService executorService) { argument
132 this.executorService = executorService;
138 ExecutorServiceConfigurator delegateConfigurator = getDelegateConfigurator(executorService);
152 executorService)
185 private ExecutorServiceConfigurator getDelegateConfigurator(ExecutorService executorService) { argument
187 if (executorService instanceof ThreadPoolExecutor) {
188 return new ExecutorServiceConfigurator((ThreadPoolExecutor) executorService);
190 } else if (executorService instanceo
[all...]
/forgerock/openam/openam-core/src/main/java/com/iplanet/dpro/session/monitoring/
H A DSessionMonitoringStore.java44 private final ExecutorService executorService; field in class:SessionMonitoringStore
52 * @param executorService the service to which to offload out writes
55 public SessionMonitoringStore(@Named(EXECUTOR_BINDING_NAME) ExecutorService executorService, argument
57 this.executorService = executorService;
69 * @param executorService Service to perform writes with
76 SessionMonitoringStore(ExecutorService executorService, argument
82 this.executorService = executorService;
98 executorService
[all...]
/forgerock/openam/openam-core/src/main/java/com/iplanet/dpro/session/service/
H A DSessionTimeoutHandlerExecutor.java64 private final ExecutorService executorService; field in class:SessionTimeoutHandlerExecutor
69 final @Named(EXECUTOR_BINDING_NAME) ExecutorService executorService,
73 this.executorService = executorService;
132 futures.add(executorService.submit(timeoutTask)); // This should not throw any exceptions.
67 SessionTimeoutHandlerExecutor( final @Named(SESSION_DEBUG) Debug sessionDebug, final @Named(EXECUTOR_BINDING_NAME) ExecutorService executorService, final SSOTokenManager ssoTokenManager, final SessionServiceConfig serviceConfig) argument
/forgerock/openam-v13/openam-core/src/main/java/org/forgerock/openam/entitlement/monitoring/
H A DPolicyMonitorImpl.java54 private final ExecutorService executorService; field in class:PolicyMonitorImpl
61 * @param executorService The executor service this module should use when passing off the adding of new data
70 @Named(EXECUTOR_BINDING_NAME) ExecutorService executorService,
77 this.executorService = executorService;
94 executorService.submit(new Runnable() {
107 executorService.submit(new Runnable() {
127 executorService.submit(new Callable<Void>() {
69 PolicyMonitorImpl(@amedPOLICY_MONITOR_DEBUG) Debug debug, @Named(EXECUTOR_BINDING_NAME) ExecutorService executorService, final EvaluationMonitoringStore selfEvaluationMonitoringStore, final EvaluationTimingStore selfEvaluationTimingStore, final EvaluationMonitoringStore subtreeEvaluationMonitoringStore, final EvaluationTimingStore subtreeEvaluationTimingStore, final InternalEvaluationTimingStore internalEvaluationTimingStore) argument
/forgerock/openam/openam-core/src/main/java/org/forgerock/openam/entitlement/monitoring/
H A DPolicyMonitorImpl.java54 private final ExecutorService executorService; field in class:PolicyMonitorImpl
61 * @param executorService The executor service this module should use when passing off the adding of new data
70 @Named(EXECUTOR_BINDING_NAME) ExecutorService executorService,
77 this.executorService = executorService;
94 executorService.submit(new Runnable() {
107 executorService.submit(new Runnable() {
127 executorService.submit(new Callable<Void>() {
69 PolicyMonitorImpl(@amedPOLICY_MONITOR_DEBUG) Debug debug, @Named(EXECUTOR_BINDING_NAME) ExecutorService executorService, final EvaluationMonitoringStore selfEvaluationMonitoringStore, final EvaluationTimingStore selfEvaluationTimingStore, final EvaluationMonitoringStore subtreeEvaluationMonitoringStore, final EvaluationTimingStore subtreeEvaluationTimingStore, final InternalEvaluationTimingStore internalEvaluationTimingStore) argument
/forgerock/openam/openam-notifications/src/test/java/org/forgerock/openam/notifications/
H A DInMemoryNotificationBrokerTest.java51 private ExecutorService executorService; field in class:InMemoryNotificationBrokerTest
67 when(executorServiceFactory.createFixedThreadPool(anyInt(), anyString())).thenReturn(executorService);
81 verify(executorService, times(CONSUMERS)).submit(readerCapture.capture());
106 verify(executorService, times(CONSUMERS)).submit(readerCapture.capture());
126 verify(executorService, times(CONSUMERS)).submit(readerCapture.capture());
148 verify(executorService, times(CONSUMERS)).submit(readerCapture.capture());
209 verify(executorService, times(CONSUMERS)).submit(readerCapture.capture());
231 verify(executorService, times(CONSUMERS)).submit(readerCapture.capture());
255 verify(executorService, times(CONSUMERS)).submit(readerCapture.capture());
278 verify(executorService, time
[all...]
/forgerock/openam-v13/openam-radius/openam-radius-server/src/main/java/org/forgerock/openam/radius/server/
H A DRadiusRequestListener.java87 private final ExecutorService executorService; field in class:RadiusRequestListener
104 * @param executorService the thread pool executor to process radius requests.
111 final ExecutorService executorService,
117 this.executorService = executorService;
190 executorService.shutdown();
201 finished = executorService.awaitTermination(RadiusServerConstants.THREAD_POOL_SHUTDOWN_WAIT_SECONDS,
204 LOG.warning("InterruptedException caught while waiting for executorService to terminate.");
289 executorService.execute(requestHandler);
110 RadiusRequestListener(final RadiusServiceConfig config, final ExecutorService executorService, final EventBus eventBus, final AccessRequestHandlerFactory accessRequestHandlerFactory) argument
H A DRequestListenerFactory.java90 final ExecutorService executorService = executorServiceFactory.createThreadPool(coreSize, maxSize, idleTimeout,
92 return new RadiusRequestListener(serviceConfig, executorService, eventBus, accessRequestHandlerFactory);
/forgerock/openam/openam-radius/openam-radius-server/src/main/java/org/forgerock/openam/radius/server/
H A DRadiusRequestListener.java89 private final ExecutorService executorService; field in class:RadiusRequestListener
106 * @param executorService the thread pool executor to process radius requests.
113 final ExecutorService executorService,
119 this.executorService = executorService;
212 executorService.shutdown();
223 finished = executorService.awaitTermination(RadiusServerConstants.THREAD_POOL_SHUTDOWN_WAIT_SECONDS,
226 LOG.warning("InterruptedException caught while waiting for executorService to terminate.");
311 executorService.execute(requestHandler);
112 RadiusRequestListener(final RadiusServiceConfig config, final ExecutorService executorService, final EventBus eventBus, final AccessRequestHandlerFactory accessRequestHandlerFactory) argument
H A DRequestListenerFactory.java87 final ExecutorService executorService = executorServiceFactory.createThreadPool(coreSize, maxSize, idleTimeout,
89 return new RadiusRequestListener(serviceConfig, executorService, eventBus, accessRequestHandlerFactory);
/forgerock/openam-v13/openam-core/src/main/java/org/forgerock/openam/cts/monitoring/impl/
H A DCTSMonitoringStoreImpl.java56 private final ExecutorService executorService; field in class:CTSMonitoringStoreImpl
64 * @param executorService An instance of an ExecutorService.
69 public CTSMonitoringStoreImpl(@Named(EXECUTOR_BINDING_NAME) final ExecutorService executorService, argument
75 this.executorService = executorService;
92 executorService.submit(new Callable<Void>() {
109 executorService.submit(new Callable<Void>() {
/forgerock/openam/openam-notifications-websocket/src/main/java/org/forgerock/openam/notifications/websocket/
H A DNotificationsWebSocket.java79 private final ScheduledExecutorService executorService; field in class:NotificationsWebSocket
91 executorService = null;
101 @Named("webSocketScheduledExecutorService") ScheduledExecutorService executorService) {
105 this.executorService = executorService;
119 pingFuture = executorService.scheduleAtFixedRate(new Runnable() {
100 NotificationsWebSocket(NotificationBroker broker, TimeService timeService, @Named(�) ScheduledExecutorService executorService) argument
/forgerock/openam/openam-shared/src/test/java/org/forgerock/openam/shared/concurrency/
H A DThreadMonitorTest.java182 ExecutorService executorService = null;
184 executorService = Executors.newCachedThreadPool();
186 executorService,
206 monitor.watchThread(executorService, mockRunnable);
215 if (executorService != null) {
216 executorService.shutdown();
/forgerock/openam/openam-core/src/main/java/org/forgerock/openam/cts/monitoring/impl/
H A DCTSMonitoringStoreImpl.java56 private final ExecutorService executorService; field in class:CTSMonitoringStoreImpl
64 * @param executorService An instance of an ExecutorService.
69 public CTSMonitoringStoreImpl(@Named(EXECUTOR_BINDING_NAME) final ExecutorService executorService, argument
75 this.executorService = executorService;
92 executorService.submit(new Callable<Void>() {
109 executorService.submit(new Callable<Void>() {
/forgerock/openam-v13/openam-core/src/test/java/org/forgerock/openam/sm/datalayer/impl/
H A DSeriesTaskExecutorTest.java42 private ExecutorService executorService; field in class:SeriesTaskExecutorTest
50 executorService = mock(ExecutorService.class);
56 executor = new SeriesTaskExecutor(executorService, processorFactory, monitor, configuration, mock(Debug.class));
/forgerock/openam/openam-core/src/test/java/org/forgerock/openam/sm/datalayer/impl/
H A DSeriesTaskExecutorTest.java42 private ExecutorService executorService; field in class:SeriesTaskExecutorTest
50 executorService = mock(ExecutorService.class);
56 executor = new SeriesTaskExecutor(executorService, processorFactory, monitor, configuration, mock(Debug.class));
/forgerock/openam/openam-notifications/src/main/java/org/forgerock/openam/notifications/brokers/
H A DInMemoryNotificationBroker.java67 private final ExecutorService executorService; field in class:InMemoryNotificationBroker
89 executorService = executorServiceFactory.createFixedThreadPool(consumers, "InMemoryNotificationsBroker");
91 executorService.submit(new NotificationReader());
135 executorService.shutdownNow();
/forgerock/openam/openam-core-rest/src/main/java/org/forgerock/openam/core/rest/docs/api/
H A DApiDocsService.java215 ExecutorService executorService = new ThreadPoolExecutor(1, 1, 0, SECONDS, new LinkedBlockingQueue<Runnable>());
216 final Future<ApiDescription> description = executorService.submit(new Callable<ApiDescription>() {
232 final Future<File> asciidoc = executorService.submit(new Callable<File>() {
246 final Future<File> docs = executorService.submit(new Callable<File>() {
260 executorService.shutdown();
/forgerock/openam/openam-notifications-integration/src/main/java/org/forgerock/openam/notifications/integration/brokers/
H A DCTSNotificationBroker.java93 private final ScheduledExecutorService executorService; field in class:CTSNotificationBroker
122 executorService = executorServiceFactory.createScheduledService(1, "CTSNotificationsBroker");
127 executorService.scheduleAtFixedRate(new CTSPublisher(), publishFrequencyMilliseconds,
162 executorService.shutdownNow();
/forgerock/openam-v13/openam-core/src/test/java/org/forgerock/openam/cts/monitoring/
H A DCTSMonitoringStoreImplTest.java54 final ExecutorService executorService = mock(ExecutorService.class);
60 executorService,
67 given(executorService.submit(any(Callable.class))).will(new Answer<Object>() {
/forgerock/openam/openam-core/src/test/java/org/forgerock/openam/cts/monitoring/
H A DCTSMonitoringStoreImplTest.java54 final ExecutorService executorService = mock(ExecutorService.class);
60 executorService,
67 given(executorService.submit(any(Callable.class))).will(new Answer<Object>() {
/forgerock/openam/openam-notifications-websocket/src/test/java/org/forgerock/openam/notifications/websocket/
H A DNotificationsWebSocketTest.java74 private ScheduledExecutorService executorService; field in class:NotificationsWebSocketTest
86 notificationsWebSocket = new NotificationsWebSocket(broker, timeService, executorService);
115 verify(executorService).scheduleAtFixedRate(any(Runnable.class), eq(30 * 1000L), eq(30 * 1000L),
124 verify(executorService).scheduleAtFixedRate(runnableCaptor.capture(), anyLong(), anyLong(),
373 when(executorService.scheduleAtFixedRate(any(Runnable.class), anyLong(), anyLong(), any(TimeUnit.class)))
/forgerock/openam/openam-notifications-integration/src/test/java/org/forgerock/openam/notifications/brokers/
H A DCTSNotificationBrokerTest.java74 private ScheduledExecutorService executorService; field in class:CTSNotificationBrokerTest
90 when(executorServiceFactory.createScheduledService(anyInt(), anyString())).thenReturn(executorService);
101 verify(executorService).scheduleAtFixedRate(any(Runnable.class), eq(100L), eq(100L), eq(TimeUnit.MILLISECONDS));
295 verify(executorService).scheduleAtFixedRate(publisherTaskCaptor.capture(), anyLong(), anyLong(),

Completed in 100 milliseconds

12