Search Options

Results per page
Sort
Preferred Languages
Advance

Results 11 - 20 of 23 for setDaemon (0.21 sec)

  1. guava/src/com/google/common/base/internal/Finalizer.java

          }
        }
        if (thread == null) {
          thread = new Thread((ThreadGroup) null, finalizer, threadName);
        }
        thread.setDaemon(true);
    
        try {
          if (inheritableThreadLocals != null) {
            inheritableThreadLocals.set(thread, null);
          }
        } catch (Throwable t) {
          logger.log(
              Level.INFO,
    Java
    - Registered: Fri Apr 05 12:43:09 GMT 2024
    - Last Modified: Wed Aug 23 12:54:09 GMT 2023
    - 9.4K bytes
    - Viewed (0)
  2. android/guava-tests/benchmark/com/google/common/collect/ConcurrentHashMultisetBenchmark.java

        for (int i = 0; i < size; i++) {
          builder.add(i);
        }
        keys = builder.build();
        threadPool =
            Executors.newFixedThreadPool(threads, new ThreadFactoryBuilder().setDaemon(true).build());
      }
    
      @Benchmark
      long add(final int reps) throws ExecutionException, InterruptedException {
        return doMultithreadedLoop(
            new Callable<Long>() {
              @Override
    Java
    - Registered: Fri May 03 12:43:13 GMT 2024
    - Last Modified: Thu Apr 06 12:56:11 GMT 2023
    - 16.6K bytes
    - Viewed (0)
  3. guava-tests/test/com/google/common/util/concurrent/GeneratedMonitorTest.java

              }
            });
        awaitUninterruptibly(enteredLatch);
      }
    
      @CanIgnoreReturnValue
      static Thread startThread(Runnable runnable) {
        Thread thread = new Thread(runnable);
        thread.setDaemon(true);
        thread.start();
        return thread;
      }
    
      /**
       * Generates a test case verifying that calling any enterXxx, tryEnterXxx, or waitForXxx method
    Java
    - Registered: Fri Apr 12 12:43:09 GMT 2024
    - Last Modified: Mon Apr 17 14:48:57 GMT 2023
    - 27.4K bytes
    - Viewed (0)
  4. maven-compat/src/main/java/org/apache/maven/artifact/resolver/DefaultArtifactResolver.java

            public Thread newThread(Runnable r) {
                Thread newThread = new Thread(GROUP, r, "resolver-" + THREAD_NUMBER.getAndIncrement());
                newThread.setDaemon(true);
                newThread.setContextClassLoader(null);
                return newThread;
            }
        }
    
        private class ResolveTask implements Runnable {
    
            private final ClassLoader classLoader;
    Java
    - Registered: Sun May 05 03:35:11 GMT 2024
    - Last Modified: Thu Apr 25 05:46:50 GMT 2024
    - 24.8K bytes
    - Viewed (0)
  5. src/main/java/org/codelibs/fess/helper/WebFsIndexHelper.java

            indexUpdater.setName("IndexUpdater");
            indexUpdater.setPriority(indexUpdaterPriority);
            indexUpdater.setSessionIdList(sessionIdList);
            indexUpdater.setDaemon(true);
            indexUpdater.setCrawlerList(crawlerList);
            getAvailableBoostDocumentRuleList().forEach(rule -> {
                indexUpdater.addDocBoostMatcher(new org.codelibs.fess.indexer.DocBoostMatcher(rule));
    Java
    - Registered: Mon May 06 08:04:11 GMT 2024
    - Last Modified: Thu Feb 22 01:37:57 GMT 2024
    - 22.6K bytes
    - Viewed (0)
  6. guava-tests/test/com/google/common/util/concurrent/UninterruptiblesTest.java

                } catch (InterruptedException e) {
                  // simply finish execution
                } finally {
                  lock.unlock();
                }
              }
            };
        thread.setDaemon(true);
        thread.start();
        awaitUninterruptibly(latch);
        return thread;
      }
    
      private static class TestCondition implements Condition {
        private final Lock lock;
    Java
    - Registered: Fri Apr 12 12:43:09 GMT 2024
    - Last Modified: Wed Feb 09 22:57:07 GMT 2022
    - 31.7K bytes
    - Viewed (0)
  7. android/guava-tests/test/com/google/common/util/concurrent/GeneratedMonitorTest.java

              }
            });
        awaitUninterruptibly(enteredLatch);
      }
    
      @CanIgnoreReturnValue
      static Thread startThread(Runnable runnable) {
        Thread thread = new Thread(runnable);
        thread.setDaemon(true);
        thread.start();
        return thread;
      }
    
      /**
       * Generates a test case verifying that calling any enterXxx, tryEnterXxx, or waitForXxx method
    Java
    - Registered: Fri May 03 12:43:13 GMT 2024
    - Last Modified: Mon Apr 17 14:48:57 GMT 2023
    - 26.1K bytes
    - Viewed (0)
  8. android/guava-tests/test/com/google/common/util/concurrent/UninterruptiblesTest.java

                } catch (InterruptedException e) {
                  // simply finish execution
                } finally {
                  lock.unlock();
                }
              }
            };
        thread.setDaemon(true);
        thread.start();
        awaitUninterruptibly(latch);
        return thread;
      }
    
      private static class TestCondition implements Condition {
        private final Lock lock;
    Java
    - Registered: Fri May 03 12:43:13 GMT 2024
    - Last Modified: Wed Feb 09 22:57:07 GMT 2022
    - 30.9K bytes
    - Viewed (0)
  9. android/guava/src/com/google/common/util/concurrent/MoreExecutors.java

      }
    
      @J2ktIncompatible
      @GwtIncompatible // TODO
      private static void useDaemonThreadFactory(ThreadPoolExecutor executor) {
        executor.setThreadFactory(
            new ThreadFactoryBuilder()
                .setDaemon(true)
                .setThreadFactory(executor.getThreadFactory())
                .build());
      }
    
      // See newDirectExecutorService javadoc for behavioral notes.
      @J2ktIncompatible
      @GwtIncompatible // TODO
    Java
    - Registered: Fri Apr 26 12:43:10 GMT 2024
    - Last Modified: Wed Apr 17 16:33:44 GMT 2024
    - 41.8K bytes
    - Viewed (0)
  10. android/guava-tests/test/com/google/common/util/concurrent/JSR166TestCase.java

      }
    
      /** Returns a new started daemon Thread running the given runnable. */
      Thread newStartedThread(Runnable runnable) {
        Thread t = new Thread(runnable);
        t.setDaemon(true);
        t.start();
        return t;
      }
    
      /**
       * Waits for the specified time (in milliseconds) for the thread to terminate (using {@link
    Java
    - Registered: Fri May 03 12:43:13 GMT 2024
    - Last Modified: Thu Feb 22 17:15:24 GMT 2024
    - 37.2K bytes
    - Viewed (0)
Back to top