- Sort Score
- Num 10 results
- Language All
Results 181 - 190 of 961 for Spread (0.04 seconds)
-
src/test/java/jcifs/SmbTransportPoolTest.java
// When - simulate concurrent requests Thread thread1 = new Thread(() -> transportPool.getSmbTransport(context, address, DEFAULT_PORT, false)); Thread thread2 = new Thread(() -> transportPool.getSmbTransport(context, address, DEFAULT_PORT, true)); thread1.start(); thread2.start();Created: Sat Dec 20 13:44:44 GMT 2025 - Last Modified: Thu Aug 14 05:31:44 GMT 2025 - 22.6K bytes - Click Count (0) -
fess-crawler/src/main/java/org/codelibs/fess/crawler/extractor/impl/HtmlExtractor.java
throw new CrawlerSystemException("Invalid parser configuration.", e); } } /** * Gets a thread-local XPathAPI instance for thread-safe XPath evaluation. * * @return the XPathAPI instance for the current thread */ protected XPathAPI getXPathAPI() { XPathAPI cachedXPathAPI = xpathAPI.get(); if (cachedXPathAPI == null) {
Created: Sat Dec 20 11:21:39 GMT 2025 - Last Modified: Sat Oct 04 08:47:19 GMT 2025 - 9.3K bytes - Click Count (0) -
guava/src/com/google/common/collect/Interners.java
/* Someone beat us to it! Trying again... * * Technically this loop not guaranteed to terminate, so theoretically (extremely * unlikely) this thread might starve, but even then, there is always going to be another * thread doing progress here. */ } } } } /**Created: Fri Dec 26 12:43:10 GMT 2025 - Last Modified: Thu Jul 17 15:26:41 GMT 2025 - 6K bytes - Click Count (0) -
src/main/java/org/codelibs/fess/app/web/admin/plugin/AdminPluginAction.java
} /** * Installs the specified artifact in a background thread. * Also removes any previously installed versions of the same plugin. * * @param artifact the artifact to install */ public static void installArtifact(final Artifact artifact) { new Thread(() -> { final PluginHelper pluginHelper = ComponentUtil.getPluginHelper();Created: Sat Dec 20 09:19:18 GMT 2025 - Last Modified: Thu Aug 07 03:06:29 GMT 2025 - 11.9K bytes - Click Count (0) -
guava-tests/test/com/google/common/util/concurrent/AbstractExecutionThreadServiceTest.java
private final CountDownLatch exitRun = new CountDownLatch(1); private Thread executionThread; private Throwable thrownByExecutionThread; private final Executor exceptionCatchingExecutor = new Executor() { @Override public void execute(Runnable command) { executionThread = new Thread(command); executionThread.setUncaughtExceptionHandler(
Created: Fri Dec 26 12:43:10 GMT 2025 - Last Modified: Tue Oct 28 16:03:47 GMT 2025 - 12.9K bytes - Click Count (0) -
src/main/java/jcifs/smb/MultiChannelManager.java
// Create thread pools this.channelExecutor = Executors.newCachedThreadPool(r -> { Thread t = new Thread(r, "SMB3-MultiChannel-Worker"); t.setDaemon(true); return t; }); this.healthCheckExecutor = Executors.newScheduledThreadPool(2, r -> { Thread t = new Thread(r, "SMB3-MultiChannel-HealthCheck");Created: Sat Dec 20 13:44:44 GMT 2025 - Last Modified: Sun Aug 31 08:00:57 GMT 2025 - 20.5K bytes - Click Count (0) -
compat/maven-compat/src/test/java/org/apache/maven/artifact/testutils/TestFileManager.java
private List<File> filesToDelete = new ArrayList<>(); private final String baseFilename; private final String fileSuffix; private StackTraceElement callerInfo; private Thread cleanupWarning; private boolean warnAboutCleanup = false; public TestFileManager(String baseFilename, String fileSuffix) { this.baseFilename = baseFilename; this.fileSuffix = fileSuffix;Created: Sun Dec 28 03:35:09 GMT 2025 - Last Modified: Wed Sep 17 10:01:14 GMT 2025 - 4.8K bytes - Click Count (0) -
src/main/java/org/codelibs/core/concurrent/CommonPoolUtil.java
* * @param task * the task to execute */ public static void execute(final Runnable task) { ForkJoinPool.commonPool().execute(() -> { final Thread currentThread = Thread.currentThread(); final ClassLoader orignal = currentThread.getContextClassLoader(); currentThread.setContextClassLoader(CommonPoolUtil.class.getClassLoader()); try {Created: Sat Dec 20 08:55:33 GMT 2025 - Last Modified: Thu Jul 31 08:16:49 GMT 2025 - 1.7K bytes - Click Count (0) -
api/maven-api-annotations/src/main/java/org/apache/maven/api/annotations/ThreadSafe.java
import java.lang.annotation.RetentionPolicy; import java.lang.annotation.Target; /** * The {@code ThreadSafe} annotation can be used to indicate a given type * is thread safe. {@link Immutable} objects are automatically thread safe. * * @see Immutable * @see NotThreadSafe * @since 4.0.0 */ @Experimental @Documented @Retention(RetentionPolicy.CLASS) @Target(ElementType.TYPE)Created: Sun Dec 28 03:35:09 GMT 2025 - Last Modified: Tue Dec 10 21:43:27 GMT 2024 - 1.4K bytes - Click Count (0) -
impl/maven-core/src/main/java/org/apache/maven/DefaultMaven.java
ClassLoader originalClassLoader = Thread.currentThread().getContextClassLoader(); try { for (AbstractMavenLifecycleParticipant listener : getExtensionComponents(session.getProjects(), AbstractMavenLifecycleParticipant.class)) { Thread.currentThread().setContextClassLoader(listener.getClass().getClassLoader());
Created: Sun Dec 28 03:35:09 GMT 2025 - Last Modified: Mon May 05 16:58:52 GMT 2025 - 28.7K bytes - Click Count (1)