- Sort Score
- Num 10 results
- Language All
Results 201 - 210 of 232 for nThreads (0.08 seconds)
-
doc/go_mem.html
</p> <h3 id="once">Once</h3> <p> The <code>sync</code> package provides a safe mechanism for initialization in the presence of multiple goroutines through the use of the <code>Once</code> type. Multiple threads can execute <code>once.Do(f)</code> for a particular <code>f</code>, but only one will run <code>f()</code>, and the other calls block until <code>f()</code> has returned. </p> <p class="rule">
Created: Tue Dec 30 11:13:12 GMT 2025 - Last Modified: Tue Aug 05 15:41:37 GMT 2025 - 26.6K bytes - Click Count (0) -
src/main/java/org/codelibs/fess/thumbnail/ThumbnailManager.java
}, "ThumbnailGenerator"); thumbnailQueueThread.start(); } /** * Cleans up resources when the thumbnail manager is destroyed. * Stops background processing and waits for threads to complete. */ @PreDestroy public void destroy() { generating = false; thumbnailQueueThread.interrupt(); try { thumbnailQueueThread.join(10000);
Created: Sat Dec 20 09:19:18 GMT 2025 - Last Modified: Fri Nov 28 16:29:12 GMT 2025 - 27K bytes - Click Count (0) -
android/guava/src/com/google/common/collect/ConcurrentHashMultiset.java
return (existingCounter == null) ? 0 : existingCounter.get(); } /** * {@inheritDoc} * * <p>If the data in the multiset is modified by any other threads during this method, it is * undefined which (if any) of these modifications will be reflected in the result. */ @Override public int size() { long sum = 0L;
Created: Fri Dec 26 12:43:10 GMT 2025 - Last Modified: Mon Dec 08 22:42:14 GMT 2025 - 22.3K bytes - Click Count (0) -
android/guava-tests/test/com/google/common/util/concurrent/MoreExecutorsTest.java
assertThrows(RejectedExecutionException.class, () -> executor.submit(() -> {})); assertTrue(executor.isTerminated()); otherTask.get(); } /** * Test for a bug where threads weren't getting signaled when shutdown was called, only when tasks * completed. */ public void testDirectExecutorService_awaitTermination_missedSignal() { ExecutorService service = newDirectExecutorService();
Created: Fri Dec 26 12:43:10 GMT 2025 - Last Modified: Fri Dec 12 00:25:21 GMT 2025 - 26.5K bytes - Click Count (0) -
android/guava/src/com/google/common/collect/ImmutableCollection.java
* ImmutableMultiset#elementSet} iterate in the same order as the parent, except as noted. * <li><b>Thread safety.</b> It is safe to access this collection concurrently from multiple * threads. * <li><b>Integrity.</b> This type cannot be subclassed outside this package (which would allow * these guarantees to be violated). * </ul> * * <h4>"Interfaces", not implementations</h4> *
Created: Fri Dec 26 12:43:10 GMT 2025 - Last Modified: Thu Aug 07 16:05:33 GMT 2025 - 21.4K bytes - Click Count (0) -
src/main/java/org/codelibs/fess/rank/fusion/RankFusionProcessor.java
numThreads = Runtime.getRuntime().availableProcessors() * 3 / 2 + 1; } if (logger.isDebugEnabled()) { logger.debug("Initializing executor service with {} threads", numThreads); } executorService = Executors.newFixedThreadPool(numThreads); } } }
Created: Sat Dec 20 09:19:18 GMT 2025 - Last Modified: Fri Nov 28 16:29:12 GMT 2025 - 27.5K bytes - Click Count (0) -
docs/tr/docs/async.md
## Çok Teknik Detaylar /// warning Muhtemelen burayı atlayabilirsiniz. Bunlar, **FastAPI**'nin altta nasıl çalıştığına dair çok teknik ayrıntılardır. Biraz teknik bilginiz varsa (co-routines, threads, blocking, vb)ve FastAPI'nin "async def" ile normal "def" arasındaki farkı nasıl işlediğini merak ediyorsanız, devam edin. /// ### Path fonksiyonu
Created: Sun Dec 28 07:19:09 GMT 2025 - Last Modified: Sun Aug 31 09:56:21 GMT 2025 - 21.8K bytes - Click Count (0) -
src/main/java/org/codelibs/fess/mylasta/direction/FessConfig.java
* Get the value for the key 'crawler.hotthread.threads'. <br> * The value is, e.g. 3 <br> * comment: Number of threads for hot thread monitoring. * @return The value of found property. (NotNull: if not found, exception but basically no way) */ String getCrawlerHotthreadThreads(); /** * Get the value for the key 'crawler.hotthread.threads' as {@link Integer}. <br>
Created: Sat Dec 20 09:19:18 GMT 2025 - Last Modified: Sat Dec 13 02:21:17 GMT 2025 - 525.7K bytes - Click Count (2) -
guava/src/com/google/common/util/concurrent/Striped.java
public abstract int size(); /** * Returns the stripes that correspond to the passed objects, in ascending (as per {@link * #getAt(int)}) order. Thus, threads that use the stripes in the order returned by this method * are guaranteed to not deadlock each other. * * <p>It should be noted that using a {@code Striped<L>} with relatively few stripes, and {@code
Created: Fri Dec 26 12:43:10 GMT 2025 - Last Modified: Tue Sep 16 22:01:32 GMT 2025 - 20.6K bytes - Click Count (0) -
guava/src/com/google/common/util/concurrent/AbstractScheduledService.java
// A handle to the running task so that we can stop it when a shutdown has been requested. // These two fields are volatile because their values will be accessed from multiple threads. private volatile @Nullable Cancellable runningTask; private volatile @Nullable ScheduledExecutorService executorService;Created: Fri Dec 26 12:43:10 GMT 2025 - Last Modified: Sat Aug 09 01:14:59 GMT 2025 - 27.8K bytes - Click Count (0)