- Sort Score
- Result 10 results
- Languages All
Results 21 - 28 of 28 for setDaemon (0.25 sec)
-
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 Apr 26 12:43:10 GMT 2024 - Last Modified: Thu Apr 06 12:56:11 GMT 2023 - 16.6K bytes - Viewed (0) -
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 Apr 26 12:43:10 GMT 2024 - Last Modified: Wed Feb 09 22:57:07 GMT 2022 - 30.9K bytes - Viewed (0) -
src/main/java/jcifs/util/transport/Transport.java
log.debug("Connecting " + this.name); } this.state = 1; this.te = null; Thread t = new Thread(this, this.name); t.setDaemon(true); this.thread = t; synchronized ( this.thread ) { t.start(); t.wait(timeout); /* wait for doConnect */ st = this.state;
Java - Registered: Sun Apr 28 00:10:09 GMT 2024 - Last Modified: Sun Nov 01 18:12:21 GMT 2020 - 24.1K bytes - Viewed (0) -
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) -
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 Apr 12 12:43:09 GMT 2024 - Last Modified: Thu Feb 22 17:15:24 GMT 2024 - 37.7K bytes - Viewed (0) -
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 Apr 26 12:43:10 GMT 2024 - Last Modified: Thu Feb 22 17:15:24 GMT 2024 - 37.2K bytes - Viewed (0) -
src/main/java/jcifs/smb/SmbFile.java
throw new SmbException("Source and destination paths overlap."); } WriterThread w = new WriterThread(); w.setDaemon(true); try { w.start(); // use commonly acceptable buffer size int bsize = Math.min(sh.getReceiveBufferSize() - 70, dh.getSendBufferSize() - 70);
Java - Registered: Sun Apr 28 00:10:09 GMT 2024 - Last Modified: Mon Mar 13 12:00:57 GMT 2023 - 81.6K bytes - Viewed (0) -
src/main/java/jcifs/smb1/smb1/SmbFile.java
throw new SmbException( "Source and destination paths overlap." ); } } catch (UnknownHostException uhe) { } w = new WriterThread(); w.setDaemon( true ); w.start(); /* Downgrade one transport to the lower of the negotiated buffer sizes * so we can just send whatever is received. */
Java - Registered: Sun Apr 28 00:10:09 GMT 2024 - Last Modified: Mon Mar 13 12:00:57 GMT 2023 - 107.9K bytes - Viewed (2)