Searched defs:executor (Results 1 - 17 of 17) sorted by relevance

/forgerock/openam-v13/openam-radius/openam-radius-server/src/main/java/org/forgerock/openam/radius/server/
H A DDroppedRequestHandler.java39 * @param executor
40 * the executor
43 public void rejectedExecution(Runnable r, ThreadPoolExecutor executor) { argument
/forgerock/openam/openam-radius/openam-radius-server/src/main/java/org/forgerock/openam/radius/server/
H A DDroppedRequestHandler.java39 * @param executor
40 * the executor
43 public void rejectedExecution(Runnable r, ThreadPoolExecutor executor) { argument
/forgerock/openam-v13/openam-core/src/test/java/org/forgerock/openam/sm/datalayer/impl/
H A DSimpleTaskExecutorTest.java37 private SimpleTaskExecutor<Closeable> executor; field in class:SimpleTaskExecutorTest
45 executor = new SimpleTaskExecutor<Closeable>(connectionFactory, mock(Debug.class), adapter);
55 executor.start();
58 executor.execute(null, task);
69 executor.start();
72 executor.finalize();
84 executor.start();
87 executor.execute(null, mock(Task.class));
88 executor.execute(null, mock(Task.class));
H A DSeriesTaskExecutorTest.java43 private SeriesTaskExecutor executor; field in class:SeriesTaskExecutorTest
56 executor = new SeriesTaskExecutor(executorService, processorFactory, monitor, configuration, mock(Debug.class));
72 executor.start();
88 executor.start();
91 executor.execute("123", mock(Task.class));
107 executor.start();
108 executor.execute("123", task); // First create fills the queue
113 executor.execute("123", task); // Second create causes timeout.
H A DPooledTaskExecutorTest.java72 final TaskExecutor executor = new PooledTaskExecutor(simpleTaskExecutorProvider, debug,
75 TaskThread task1 = new TaskThread(1, executor, longTask1);
77 TaskThread task2 = new TaskThread(2, executor, longTask2);
78 TaskThread task3 = new TaskThread(3, executor, mock(Task.class));
128 private TaskExecutor executor; field in class:PooledTaskExecutorTest.TaskThread
131 TaskThread(int taskId, TaskExecutor executor, Task task) { argument
132 this.executor = executor;
140 executor.execute(null, task);
/forgerock/openam/openam-core/src/test/java/org/forgerock/openam/sm/datalayer/impl/
H A DSimpleTaskExecutorTest.java30 private SimpleTaskExecutor executor; field in class:SimpleTaskExecutorTest
36 executor = new SimpleTaskExecutor(mock(Debug.class), adapter);
43 executor.start();
46 executor.execute(null, task);
H A DSeriesTaskExecutorTest.java43 private SeriesTaskExecutor executor; field in class:SeriesTaskExecutorTest
56 executor = new SeriesTaskExecutor(executorService, processorFactory, monitor, configuration, mock(Debug.class));
72 executor.start();
88 executor.start();
91 executor.execute("123", mock(Task.class));
107 executor.start();
108 executor.execute("123", task); // First create fills the queue
113 executor.execute("123", task); // Second create causes timeout.
H A DPooledTaskExecutorTest.java73 final TaskExecutor executor = new PooledTaskExecutor(simpleTaskExecutorProvider, debug,
76 TaskThread task1 = new TaskThread(1, executor, longTask1);
78 TaskThread task2 = new TaskThread(2, executor, longTask2);
79 TaskThread task3 = new TaskThread(3, executor, mock(Task.class));
129 private TaskExecutor executor; field in class:PooledTaskExecutorTest.TaskThread
132 TaskThread(int taskId, TaskExecutor executor, Task task) { argument
133 this.executor = executor;
141 executor.execute(null, task);
/forgerock/openidm-v4/openidm-smartevent/src/main/java/org/forgerock/openidm/smartevent/core/
H A DDisruptorReferringPublisher.java55 static Executor executor = Executors.newCachedThreadPool(); field in class:DisruptorReferringPublisher
58 RING_SIZE, executor, ProducerType.MULTI, new SleepingWaitStrategy());
H A DDisruptorShortPublisher.java55 static Executor executor = Executors.newCachedThreadPool(); field in class:DisruptorShortPublisher
57 DisruptorShortEventEntry.EVENT_FACTORY,RING_SIZE, executor, ProducerType.SINGLE, new SleepingWaitStrategy());
/forgerock/opendj-v3/opendj-maven-plugin/src/main/java/org/forgerock/opendj/maven/
H A DGenerateConfigMojo.java226 final Templates stylesheet, final ExecutorService executor, final String... parameters)
228 final Future<Void> future = executor.submit(new Callable<Void>() {
245 final ExecutorService executor, final String... parameters) throws Exception {
249 createTransformTask(inputFactory, output, stylesheet, executor, parameters);
265 * serialized by using a single threaded executor.
225 createTransformTask(final StreamSourceFactory inputFactory, final StreamResult output, final Templates stylesheet, final ExecutorService executor, final String... parameters) argument
243 createTransformTask(final StreamSourceFactory inputFactory, final String outputFileName, final Templates stylesheet, final ExecutorService executor, final String... parameters) argument
/forgerock/openidm-v4/openidm-scheduler/src/main/java/org/forgerock/openidm/scheduler/impl/
H A DTaskScannerJob.java74 final ExecutorService executor = Executors.newFixedThreadPool(numberOfThreads);
78 performTask(executor);
82 executor.shutdown();
91 performTask(executor);
95 executor.shutdown();
109 * @param executor ExecutorService in which to invoke this task.
112 private void performTask(ExecutorService executor) argument
155 executor.invokeAll(todo);
/forgerock/openidm-v4/openidm-core/src/main/java/org/forgerock/openidm/sync/impl/
H A DReconciliationContext.java56 private ExecutorService executor; field in class:ReconciliationContext
99 // Initialize the executor for this recon, or null if no executor should be used
102 executor = Executors.newFixedThreadPool(noOfThreads);
104 executor = null;
262 * @return the executor for this recon, or null if no executor should be used
265 return executor;
392 if (executor != null) {
393 executor
[all...]
/forgerock/opendj-v3/opendj-server-legacy/src/main/java/org/opends/server/backends/pluggable/
H A DOnDiskMergeImporter.java548 private final ExecutorService executor; field in class:OnDiskMergeImporter.LDIFReaderSource
562 this.executor = Executors.newFixedThreadPool(nbThreads, newThreadFactory(null, threadNameTemplate, true));
571 final CompletionService<Void> completion = new ExecutorCompletionService<>(executor);
619 executor.shutdown();
689 private final ExecutorService executor; field in class:OnDiskMergeImporter.ID2EntrySource
702 this.executor =
709 public void rejectedExecution(Runnable r, ThreadPoolExecutor executor)
714 executor.getQueue().put(r);
737 executor.submit(new Runnable()
759 executor
[all...]
/forgerock/authenticator-android-v2/app/libs/
H A Dpicasso-2.4.0.jarMETA-INF/ META-INF/MANIFEST.MF com/ com/squareup/ com/squareup/picasso/ com/squareup/picasso/Action ...
/forgerock/openam-v13/openam-oauth/samples/StockClient/lib/
H A Djavaee.jarMETA-INF/ META-INF/MANIFEST.MF javax/ javax/servlet/ javax/servlet/jsp/ javax/servlet/jsp/jstl/ ...
/forgerock/openam-v13/openam-oauth/samples/StockService/lib/
H A Djavaee.jarMETA-INF/ META-INF/MANIFEST.MF javax/ javax/servlet/ javax/servlet/jsp/ javax/servlet/jsp/jstl/ ...

Completed in 308 milliseconds