Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 5 of 5 for CountDownLatch (0.3 sec)

  1. 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)
  2. 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)
  3. 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)
  4. 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)
  5. 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)
Back to top