- Sort Score
- Result 10 results
- Languages All
Results 171 - 180 of 692 for threadId (0.06 sec)
-
src/main/java/org/codelibs/fess/thumbnail/ThumbnailManager.java
* Stops background processing and waits for threads to complete. */ @PreDestroy public void destroy() { generating = false; thumbnailQueueThread.interrupt(); try { thumbnailQueueThread.join(10000); } catch (final InterruptedException e) { logger.warn("Thumbnail thread timed out.", e); } generatorList.forEach(g -> {Registered: Sat Dec 20 09:19:18 UTC 2025 - Last Modified: Fri Nov 28 16:29:12 UTC 2025 - 27K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/cache/CacheBuilderTest.java
threadPool.shutdown(); threadPool.awaitTermination(300, SECONDS); } /** * Calls get() repeatedly from many different threads, and tests that all of the removed entries * (removed because of size limits or expiration) trigger appropriate removal notifications. */ @GwtIncompatible // QueuingRemovalListener
Registered: Fri Dec 26 12:43:10 UTC 2025 - Last Modified: Tue Sep 30 22:03:28 UTC 2025 - 25.4K bytes - Viewed (0) -
guava/src/com/google/common/util/concurrent/AbstractScheduledService.java
* instance. This method is guaranteed to only be called once. * * <p>By default this returns a new {@link ScheduledExecutorService} with a single thread pool * that sets the name of the thread to the {@linkplain #serviceName() service name}. Also, the * pool will be {@linkplain ScheduledExecutorService#shutdown() shut down} when the serviceRegistered: Fri Dec 26 12:43:10 UTC 2025 - Last Modified: Sat Aug 09 01:14:59 UTC 2025 - 27.8K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/collect/SynchronizedTableTest.java
@Override public String toString() { assertTrue(Thread.holdsLock(mutex)); return delegate.toString(); } @Override public boolean equals(@Nullable Object o) { assertTrue(Thread.holdsLock(mutex)); return delegate.equals(o); } @Override public int hashCode() { assertTrue(Thread.holdsLock(mutex)); return delegate.hashCode(); }Registered: Fri Dec 26 12:43:10 UTC 2025 - Last Modified: Wed Jul 16 17:42:14 UTC 2025 - 4.7K bytes - Viewed (0) -
src/main/java/jcifs/smb1/netbios/NameServiceClient.java
// be ignored; see tryClose comment. if (socket == null) { socket = new DatagramSocket(lport, laddr); thread = new Thread(this, "JCIFS-NameServiceClient"); thread.setDaemon(true); thread.start(); } } void tryClose() { synchronized (LOCK) { /* Yes, there is the potential to drop packetsRegistered: Sat Dec 20 13:44:44 UTC 2025 - Last Modified: Thu Aug 14 07:14:38 UTC 2025 - 17.6K bytes - Viewed (0) -
src/main/java/org/codelibs/core/lang/ClassUtil.java
primitiveNameToClassMap.put(Double.TYPE.getName(), Double.TYPE); } /** * Returns the {@link Class} object associated with the class or interface with the given string name, * using the current thread's context class loader. * * @param <T> * The class represented by the returned {@link Class} object * @param className
Registered: Sat Dec 20 08:55:33 UTC 2025 - Last Modified: Thu Jul 31 08:16:49 UTC 2025 - 25.6K bytes - Viewed (0) -
guava-tests/test/com/google/common/collect/SynchronizedDequeTest.java
@Override public boolean offer(E o) { assertTrue(Thread.holdsLock(mutex)); return delegate.offer(o); } @Override public @Nullable E poll() { assertTrue(Thread.holdsLock(mutex)); return delegate.poll(); } @Override public E remove() { assertTrue(Thread.holdsLock(mutex)); return delegate.remove(); } @OverrideRegistered: Fri Dec 26 12:43:10 UTC 2025 - Last Modified: Wed Jul 16 17:42:14 UTC 2025 - 7.4K bytes - Viewed (0) -
guava-tests/test/com/google/common/util/concurrent/InterruptionUtil.java
} } void stopInterrupting() { shouldStop = true; } } /** Interrupts the current thread after sleeping for the specified delay. */ static void requestInterruptIn(long time, TimeUnit unit) { checkNotNull(unit); Thread interruptee = Thread.currentThread(); new Thread( new Runnable() { @Override public void run() { try {Registered: Fri Dec 26 12:43:10 UTC 2025 - Last Modified: Sun Aug 10 19:54:19 UTC 2025 - 4.5K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/collect/SynchronizedQueueTest.java
@Override public boolean offer(E o) { assertTrue(Thread.holdsLock(mutex)); return delegate.offer(o); } @Override public @Nullable E poll() { assertTrue(Thread.holdsLock(mutex)); return delegate.poll(); } @Override public E remove() { assertTrue(Thread.holdsLock(mutex)); return delegate.remove(); } @OverrideRegistered: Fri Dec 26 12:43:10 UTC 2025 - Last Modified: Wed Jul 16 17:42:14 UTC 2025 - 4.8K bytes - Viewed (0) -
src/main/resources/fess_label_pt_BR.properties
labels.includedDocPaths=Caminhos a serem incluídos na pesquisa labels.includedDocUrls=URLs a serem incluídas na pesquisa labels.maxAccessCount=Número máximo de acessos labels.name=Nome labels.numOfThread=Número de threads labels.duplicateHostName=Nome duplicado labels.pageNumber=Número da página labels.password=Senha labels.paths=Caminhos labels.port=Porta labels.regex=Expressão regular labels.regularName=Nome regular
Registered: Sat Dec 20 09:19:18 UTC 2025 - Last Modified: Sat Dec 13 02:21:17 UTC 2025 - 48.7K bytes - Viewed (0)