Searched refs:executor (Results 1 - 25 of 28) sorted by relevance

12

/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/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-v13/openam-core/src/main/java/org/forgerock/openam/sm/datalayer/impl/
H A DPooledTaskExecutor.java40 * On calling {@link #execute}, a thread will be blocked until an executor from the pool becomes
60 * @param connectionType The type of connection this executor is for.
85 debug("Polling pool for an executor");
89 throw new DataLayerException("Interrupted while waiting for executor - cannot continue", e);
91 SimpleTaskExecutor executor = pool.poll();
92 if (executor == null) {
93 executor = createExecutor();
96 debug("Got an executor - executing task");
97 executor.execute(tokenId, task);
99 debug("Returning executor t
[all...]
/forgerock/openam/openam-core/src/main/java/org/forgerock/openam/sm/datalayer/impl/
H A DPooledTaskExecutor.java42 * On calling {@link #execute}, a thread will be blocked until an executor from the pool becomes
62 * @param connectionType The type of connection this executor is for.
87 debug("Polling pool for an executor");
91 throw new DataLayerException("Interrupted while waiting for executor - cannot continue", e);
93 SimpleTaskExecutor executor = pool.poll();
94 if (executor == null) {
95 executor = createExecutor();
98 debug("Got an executor - executing task");
99 executor.execute(tokenId, task);
101 debug("Returning executor t
[all...]
/forgerock/openam-v13/openam-tools/openam-diagnostics/openam-diagnostics-base/src/main/java/com/sun/identity/diagnostic/base/services/systeminfo/
H A DWindowsSystemInfoProvider.java122 ProcessExecutor executor;
126 executor = new ProcessExecutor(new String[]{"ipconfig"});
127 cmdOut = executor.execute(true);
139 executor = new ProcessExecutor(new String[]{"systeminfo"});
140 cmdOut = executor.execute(true);
H A DLinuxSystemInfoProvider.java92 ProcessExecutor executor = new ProcessExecutor(meminfo_cmd);
94 String[] cmdOp = executor.execute(true);
152 ProcessExecutor executor = new ProcessExecutor(SWAPINFO_CMD);
154 String[] cmdOp = executor.execute(true);
206 ProcessExecutor executor =
209 String[] domainName = executor.execute(true);
H A DSolarisSystemInfoProvider.java49 ProcessExecutor executor = new ProcessExecutor(
52 String[] domainName = executor.execute(true);
194 ProcessExecutor executor = new ProcessExecutor(
197 String[] cmdOp = executor.execute(true);
258 ProcessExecutor executor = new ProcessExecutor(swapSCommand);
260 String[] cmdOp = executor.execute(true);
H A DPatchCommandExecutorForHpux.java64 ProcessExecutor executor = new ProcessExecutor(
66 String[] cmdOp = executor.execute(true);
H A DPatchCommandExecutor.java71 ProcessExecutor executor = new ProcessExecutor(
73 String[] cmdOp = executor.execute(true);
/forgerock/openidm-v4/openidm-core/src/main/java/org/forgerock/openidm/sync/impl/
H A DReconFeeder.java38 * multi-threaded using an executor.
40 * Keeps the executor loaded to a desirable level, rather than filling up
67 Executor executor = reconContext.getExcecutor();
68 if (executor == null) {
80 completionService = new ExecutorCompletionService<Void>(executor);
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/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/openidm-v4/openidm-smartevent/src/main/java/org/forgerock/openidm/smartevent/core/
H A DDisruptorShortPublisher.java55 static Executor executor = Executors.newCachedThreadPool(); field in class:DisruptorShortPublisher
57 DisruptorShortEventEntry.EVENT_FACTORY,RING_SIZE, executor, ProducerType.SINGLE, new SleepingWaitStrategy());
H A DDisruptorReferringPublisher.java55 static Executor executor = Executors.newCachedThreadPool(); field in class:DisruptorReferringPublisher
58 RING_SIZE, executor, ProducerType.MULTI, new SleepingWaitStrategy());
/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-shell/src/main/java/org/forgerock/openidm/shell/impl/
H A DUpdateCommand.java151 * Registers a executor for the step it satisfies.
153 * @param stepExecutor the executor to register.
178 * For each step in the executeSequence, this executes each registered executor as long as the condition of
179 * the executor is ok to run. When all are complete, or one fails, this will then similarly loop through each
180 * step in the recoverySequence and execute its registered executor.
191 StepExecutor executor = executorRegistry.get(nextStep);
192 if (null != executor && executor.onCondition(executionResults)) {
194 if (!executor.execute(context, executionResults)) {
208 StepExecutor executor
[all...]
/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/openam-v13/openam-core/src/test/java/org/forgerock/openam/cts/utils/blob/strategies/
H A DCompressionStrategyTest.java126 final Executor executor = Executors.newFixedThreadPool(numThreads);
133 executor.execute(new CompressionTask(barrier, dataToCompress, strategy, errors, roundsPerThread));
/forgerock/openam/openam-core/src/test/java/org/forgerock/openam/cts/utils/blob/strategies/
H A DCompressionStrategyTest.java127 final Executor executor = Executors.newFixedThreadPool(numThreads);
134 executor.execute(new CompressionTask(barrier, dataToCompress, strategy, errors, roundsPerThread));
/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...]

Completed in 164 milliseconds

12