- Sort Score
- Result 10 results
- Languages All
Results 1 - 5 of 5 for CountDownLatch (0.3 sec)
-
fess-crawler/src/test/java/org/codelibs/fess/crawler/transformer/impl/AbstractTransformerTest.java
*/ public void test_concurrentNameAccess() throws Exception { final int threadCount = 100; final int operationsPerThread = 100; final CountDownLatch startLatch = new CountDownLatch(1); final CountDownLatch endLatch = new CountDownLatch(threadCount); final AtomicInteger errorCount = new AtomicInteger(0); testTransformer.setName("concurrentName");
Registered: Sun Sep 21 03:50:09 UTC 2025 - Last Modified: Sat Sep 06 04:15:37 UTC 2025 - 20.8K bytes - Viewed (0) -
fess-crawler/src/test/java/org/codelibs/fess/crawler/CrawlerContextTest.java
*/ public void test_accessCount_concurrent() throws Exception { final int threadCount = 100; final int operationsPerThread = 1000; final CountDownLatch startLatch = new CountDownLatch(1); final CountDownLatch endLatch = new CountDownLatch(threadCount); ExecutorService executor = Executors.newFixedThreadPool(threadCount); for (int i = 0; i < threadCount; i++) {
Registered: Sun Sep 21 03:50:09 UTC 2025 - Last Modified: Sat Sep 06 04:15:37 UTC 2025 - 25.6K bytes - Viewed (0) -
fess-crawler/src/test/java/org/codelibs/fess/crawler/rule/RuleManagerTest.java
final ThreadSafeRuleManager threadSafeManager = new ThreadSafeRuleManager(); final int threadCount = 10; final int rulesPerThread = 100; final CountDownLatch startLatch = new CountDownLatch(1); final CountDownLatch endLatch = new CountDownLatch(threadCount); for (int i = 0; i < threadCount; i++) { final int threadId = i; new Thread(new Runnable() { @Override
Registered: Sun Sep 21 03:50:09 UTC 2025 - Last Modified: Sat Sep 06 04:15:37 UTC 2025 - 23.8K bytes - Viewed (0) -
fess-crawler/src/test/java/org/codelibs/fess/crawler/transformer/TransformerTest.java
final int threadCount = 5; final int operationsPerThread = 10; final CountDownLatch startLatch = new CountDownLatch(1); final CountDownLatch endLatch = new CountDownLatch(threadCount); final AtomicInteger successCount = new AtomicInteger(0); ExecutorService executor = Executors.newFixedThreadPool(threadCount);
Registered: Sun Sep 21 03:50:09 UTC 2025 - Last Modified: Sat Sep 06 04:15:37 UTC 2025 - 28K bytes - Viewed (0) -
fess-crawler/src/test/java/org/codelibs/fess/crawler/rule/impl/AbstractRuleTest.java
*/ public void test_concurrentPropertyAccess() throws Exception { final int threadCount = 10; final int iterationsPerThread = 100; final CountDownLatch startLatch = new CountDownLatch(1); final CountDownLatch endLatch = new CountDownLatch(threadCount); final AtomicInteger errorCount = new AtomicInteger(0); // Set initial values testRule.setRuleId("concurrentRule");
Registered: Sun Sep 21 03:50:09 UTC 2025 - Last Modified: Wed Sep 03 14:42:53 UTC 2025 - 21.9K bytes - Viewed (0)