- Sort Score
- Num 10 results
- Language All
Results 291 - 300 of 332 for Executor (0.07 seconds)
-
src/main/java/jcifs/internal/smb2/multichannel/ChannelManager.java
import java.util.Collection; import java.util.Comparator; import java.util.Enumeration; import java.util.List; import java.util.Map; import java.util.concurrent.ConcurrentHashMap; import java.util.concurrent.Executors; import java.util.concurrent.ScheduledExecutorService; import java.util.concurrent.TimeUnit; import java.util.concurrent.atomic.AtomicInteger; import org.slf4j.Logger; import org.slf4j.LoggerFactory;
Created: Sun Apr 05 00:10:12 GMT 2026 - Last Modified: Thu Aug 21 11:13:46 GMT 2025 - 20K bytes - Click Count (0) -
android/guava-tests/test/com/google/common/util/concurrent/ThreadFactoryBuilderTest.java
* limitations under the License. */ package com.google.common.util.concurrent; import static com.google.common.truth.Truth.assertThat; import static java.util.concurrent.Executors.defaultThreadFactory; import static org.junit.Assert.assertThrows; import com.google.common.annotations.GwtIncompatible; import com.google.common.annotations.J2ktIncompatible;
Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Mon Mar 16 22:45:21 GMT 2026 - 7.8K bytes - Click Count (0) -
.teamcity/scripts/CheckBadMerge.java
* * If any "bad" merge commit is found, it will print the details and exit with non-zero code. */ public class CheckBadMerge { private static final ExecutorService THREAD_POOL = Executors.newCachedThreadPool(); private static final List<String> MONITORED_PATHS = Collections.unmodifiableList(Arrays.asList( "subprojects/docs/src/docs/release/notes.md",
Created: Wed Apr 01 11:36:16 GMT 2026 - Last Modified: Mon Mar 30 16:25:09 GMT 2026 - 9K bytes - Click Count (0) -
guava-tests/test/com/google/common/util/concurrent/JdkFutureAdaptersTest.java
import static com.google.common.util.concurrent.JdkFutureAdapters.listenInPoolThread; import static com.google.common.util.concurrent.MoreExecutors.directExecutor; import static java.util.concurrent.Executors.newCachedThreadPool; import static java.util.concurrent.TimeUnit.SECONDS; import com.google.common.annotations.GwtIncompatible; import com.google.common.annotations.J2ktIncompatible;
Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Fri Mar 13 13:01:07 GMT 2026 - 10K bytes - Click Count (0) -
android/guava-tests/test/com/google/common/util/concurrent/JdkFutureAdaptersTest.java
import static com.google.common.util.concurrent.JdkFutureAdapters.listenInPoolThread; import static com.google.common.util.concurrent.MoreExecutors.directExecutor; import static java.util.concurrent.Executors.newCachedThreadPool; import static java.util.concurrent.TimeUnit.SECONDS; import com.google.common.annotations.GwtIncompatible; import com.google.common.annotations.J2ktIncompatible;
Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Fri Mar 13 13:01:07 GMT 2026 - 10K bytes - Click Count (0) -
docs/smb3-features/04-directory-leasing-design.md
### 4.3 Directory Lease Manager ```java package jcifs.internal.smb2.lease; import java.util.concurrent.ConcurrentHashMap; import java.util.concurrent.ScheduledExecutorService; import java.util.concurrent.Executors; import java.util.concurrent.TimeUnit; public class DirectoryLeaseManager { private final CIFSContext context; private final LeaseManager baseLeaseManager; // Reuse existing lease managerCreated: Sun Apr 05 00:10:12 GMT 2026 - Last Modified: Sat Aug 16 02:53:50 GMT 2025 - 36.2K bytes - Click Count (0) -
src/main/java/jcifs/audit/SecurityAuditLogger.java
import java.util.concurrent.BlockingQueue; import java.util.concurrent.ConcurrentHashMap; import java.util.concurrent.ConcurrentLinkedQueue; import java.util.concurrent.ExecutorService; import java.util.concurrent.Executors; import java.util.concurrent.LinkedBlockingQueue; import java.util.concurrent.TimeUnit; import java.util.concurrent.atomic.AtomicLong; import java.util.regex.Pattern; import org.slf4j.Logger;
Created: Sun Apr 05 00:10:12 GMT 2026 - Last Modified: Sat Aug 30 05:58:03 GMT 2025 - 26.6K bytes - Click Count (0) -
docs/pt/docs/advanced/events.md
alto do módulo/arquivo, mas isso também significaria **carregar o modelo** mesmo se você estivesse executando um teste automatizado simples; então esse teste poderia ser **lento** porque teria que esperar o carregamento do modelo antes de conseguir executar uma parte independente do código. É isso que vamos resolver: vamos carregar o modelo antes de as requisições serem tratadas, mas apenas um pouco antes de a aplicação começar a receber requisições, não enquanto o código estiver sendo carregado....
Created: Sun Apr 05 07:19:11 GMT 2026 - Last Modified: Thu Mar 19 18:20:43 GMT 2026 - 8.7K bytes - Click Count (0) -
okhttp/src/jvmTest/kotlin/okhttp3/DuplexTest.kt
import java.io.IOException import java.net.HttpURLConnection import java.net.ProtocolException import java.util.concurrent.BlockingQueue import java.util.concurrent.CountDownLatch import java.util.concurrent.Executors import java.util.concurrent.LinkedBlockingQueue import java.util.concurrent.TimeUnit import kotlin.test.assertFailsWith import mockwebserver3.MockResponse import mockwebserver3.MockWebServer
Created: Fri Apr 03 11:42:14 GMT 2026 - Last Modified: Tue Nov 04 19:13:52 GMT 2025 - 25.8K bytes - Click Count (0) -
android/guava-tests/test/com/google/common/util/concurrent/JSR166TestCase.java
* <li>All threads generated must be joined inside each test case method (or {@code fail} to do * so) before returning from the method. The {@code joinPool} method can be used to do this * when using Executors. * </ol> * * <p><b>Other notes</b> * * <ul> * <li>Usually, there is one testcase method per JSR166 method covering "normal" operation, and
Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Sat Mar 07 02:20:33 GMT 2026 - 8.8K bytes - Click Count (0)