Searched refs:processors (Results 1 - 4 of 4) sorted by relevance

/forgerock/openam/openam-core/src/main/java/org/forgerock/openam/sm/datalayer/impl/
H A DSeriesTaskExecutor.java76 private int processors; field in class:SeriesTaskExecutor
125 processors = configuration.getProcessors();
130 taskQueues = new BlockingQueue[processors];
131 for (int ii = 0; ii < processors; ii++) {
135 for (int ii = 0; ii < processors; ii++) {
139 debug("Created {0} Task Processors", processors);
164 int select = QueueSelector.select(tokenId, processors);
/forgerock/openam-v13/openam-core/src/test/java/org/forgerock/openam/sm/datalayer/impl/
H A DSeriesTaskExecutorTest.java67 int processors = 3;
69 given(configuration.getProcessors()).willReturn(processors);
75 verify(monitor, times(processors)).watchThread(any(ExecutorService.class), any(Runnable.class));
81 int processors = 1;
86 given(configuration.getProcessors()).willReturn(processors);
/forgerock/openam/openam-core/src/test/java/org/forgerock/openam/sm/datalayer/impl/
H A DSeriesTaskExecutorTest.java67 int processors = 3;
69 given(configuration.getProcessors()).willReturn(processors);
75 verify(monitor, times(processors)).watchThread(any(ExecutorService.class), any(Runnable.class));
81 int processors = 1;
86 given(configuration.getProcessors()).willReturn(processors);
/forgerock/openam-v13/openam-core/src/main/java/org/forgerock/openam/sm/datalayer/impl/
H A DSeriesTaskExecutor.java76 private int processors; field in class:SeriesTaskExecutor
125 processors = configuration.getProcessors();
130 taskQueues = new BlockingQueue[processors];
131 for (int ii = 0; ii < processors; ii++) {
135 for (int ii = 0; ii < processors; ii++) {
139 debug("Created {0} Task Processors", processors);
164 int select = QueueSelector.select(tokenId, processors);

Completed in 39 milliseconds