Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 25 for newFixedThreadPool (0.2 sec)

  1. android/guava-tests/test/com/google/common/util/concurrent/ListenerCallQueueTest.java

      }
    
      public void testEnqueueAndDispatch_multithreaded() throws InterruptedException {
        Object listener = new Object();
        ExecutorService service = Executors.newFixedThreadPool(4);
        ListenerCallQueue<Object> queue = new ListenerCallQueue<>();
        try {
          queue.addListener(listener, service);
    
          final CountDownLatch latch = new CountDownLatch(1);
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Wed Feb 09 22:57:07 UTC 2022
    - 8.2K bytes
    - Viewed (0)
  2. guava-tests/test/com/google/common/util/concurrent/ListenerCallQueueTest.java

      }
    
      public void testEnqueueAndDispatch_multithreaded() throws InterruptedException {
        Object listener = new Object();
        ExecutorService service = Executors.newFixedThreadPool(4);
        ListenerCallQueue<Object> queue = new ListenerCallQueue<>();
        try {
          queue.addListener(listener, service);
    
          final CountDownLatch latch = new CountDownLatch(1);
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Wed Feb 09 22:57:07 UTC 2022
    - 8.2K bytes
    - Viewed (0)
  3. src/main/java/org/codelibs/fess/ds/callback/FileListIndexUpdateCallbackImpl.java

            executor = newFixedThreadPool(nThreads < 1 ? 1 : nThreads);
            final FessConfig fessConfig = ComponentUtil.getFessConfig();
            maxDeleteDocumentCacheSize = fessConfig.getIndexerDataMaxDeleteCacheSizeAsInteger();
            maxRedirectCount = fessConfig.getIndexerDataMaxRedirectCountAsInteger();
        }
    
        protected ExecutorService newFixedThreadPool(final int nThreads) {
    Registered: Thu Oct 31 13:40:30 UTC 2024
    - Last Modified: Thu Feb 22 01:37:57 UTC 2024
    - 16.8K bytes
    - Viewed (0)
  4. guava-tests/test/com/google/common/util/concurrent/AtomicLongMapBasherTest.java

        final int getsPerTask = 1000;
        final int deltaRange = 10000;
        final String key = "key";
    
        final AtomicLongMap<String> map = AtomicLongMap.create();
    
        ExecutorService threadPool = Executors.newFixedThreadPool(nThreads);
        ArrayList<Future<Long>> futures = new ArrayList<>();
        for (int i = 0; i < nTasks; i++) {
          futures.add(
              threadPool.submit(
                  new Callable<Long>() {
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Tue Feb 13 14:28:25 UTC 2024
    - 4.2K bytes
    - Viewed (0)
  5. fess-crawler/src/test/java/org/codelibs/fess/crawler/interval/impl/HostIntervalControllerTest.java

                tasks.add(testCallable);
            }
    
            // 時間取得
            final long time = System.nanoTime();
    
            // Callableタスク(複数)を実行する
            final ExecutorService executor = Executors.newFixedThreadPool(numTasks);
            try {
                final List<Future<Integer>> futures = executor.invokeAll(tasks);
                for (final Future<Integer> future : futures) {
                    future.get();
                }
    Registered: Sun Nov 10 03:50:12 UTC 2024
    - Last Modified: Thu Feb 22 01:36:27 UTC 2024
    - 3.2K bytes
    - Viewed (0)
  6. fess-crawler/src/test/java/org/codelibs/fess/crawler/client/http/HcHttpClientTest.java

        }
    
        // public void test_doGet_mt() throws Exception {
        // ExecutorService executorService = Executors.newFixedThreadPool(1);
        //
        // // HttpClient Parameters
        // Map<String, Object> paramMap = new HashMap<String, Object>();
        // httpClient.setInitParameterMap(paramMap);
        //
    Registered: Sun Nov 10 03:50:12 UTC 2024
    - Last Modified: Thu May 09 09:28:25 UTC 2024
    - 8.8K bytes
    - Viewed (0)
  7. guava-tests/test/com/google/common/util/concurrent/TrustedListenableFutureTaskTest.java

      }
    
      @J2ktIncompatible
      @GwtIncompatible // blocking wait
      public void testRunIdempotency() throws Exception {
        final int numThreads = 10;
        final ExecutorService executor = Executors.newFixedThreadPool(numThreads);
        for (int i = 0; i < 1000; i++) {
          final AtomicInteger counter = new AtomicInteger();
          final TrustedListenableFutureTask<Integer> task =
              TrustedListenableFutureTask.create(
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Mon Oct 21 15:41:36 UTC 2024
    - 7.3K bytes
    - Viewed (0)
  8. src/main/java/org/codelibs/fess/suggest/SuggesterBuilder.java

            }
    
            if (analyzer == null) {
                analyzer = SuggestUtil.createDefaultAnalyzer(client, settings);
            }
    
            if (threadPool == null) {
                threadPool = Executors.newFixedThreadPool(threadPoolSize);
            }
    
            return new Suggester(client, settings, readingConverter, contentsReadingConverter, normalizer, analyzer, threadPool);
        }
    Registered: Fri Nov 08 09:08:12 UTC 2024
    - Last Modified: Sat Oct 12 00:10:39 UTC 2024
    - 4.2K bytes
    - Viewed (0)
  9. src/main/java/org/codelibs/fess/exec/ThumbnailGenerator.java

                    logger.warn("Failed to create system properties file.", e);
                }
            }
    
            int totalCount = 0;
            int count = 1;
            final ExecutorService executorService = Executors.newFixedThreadPool(options.numOfThreads);
            try {
                while (count != 0) {
                    count = ComponentUtil.getThumbnailManager().generate(executorService, options.cleanup);
                    totalCount += count;
    Registered: Thu Oct 31 13:40:30 UTC 2024
    - Last Modified: Thu Feb 22 01:53:18 UTC 2024
    - 8.2K bytes
    - Viewed (0)
  10. android/guava-tests/test/com/google/common/util/concurrent/AbstractFutureTest.java

                    + "class java.lang.RuntimeException\\]\\]");
      }
    
      public void testCompletionFinishesWithDone() {
        ExecutorService executor = Executors.newFixedThreadPool(10);
        for (int i = 0; i < 50000; i++) {
          final AbstractFuture<String> future = new AbstractFuture<String>() {};
          final AtomicReference<String> errorMessage = Atomics.newReference();
          executor.execute(
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri Oct 18 22:10:29 UTC 2024
    - 47.1K bytes
    - Viewed (0)
Back to top