- Sort Score
- Num 10 results
- Language All
Results 591 - 600 of 1,335 for concurrent (0.16 seconds)
-
futures/failureaccess/src/module-info.java
* or implied. See the License for the specific language governing permissions and limitations under * the License. */ /** Guava: {@code Future} Internals. */ module com.google.common.util.concurrent.internal { exports com.google.common.util.concurrent.internal;Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Wed Feb 12 18:13:11 GMT 2025 - 744 bytes - Click Count (0) -
src/main/java/jcifs/internal/smb2/multichannel/ChannelFailover.java
*/ package jcifs.internal.smb2.multichannel; import java.io.IOException; import java.util.List; import java.util.concurrent.ConcurrentHashMap; import java.util.concurrent.ConcurrentMap; import java.util.concurrent.ExecutorService; import java.util.concurrent.Executors; import java.util.concurrent.TimeUnit; import org.slf4j.Logger; import org.slf4j.LoggerFactory; import jcifs.SmbTransport;
Created: Sun Apr 05 00:10:12 GMT 2026 - Last Modified: Thu Aug 21 11:13:46 GMT 2025 - 11.6K bytes - Click Count (0) -
guava-testlib/src/com/google/common/testing/FakeTicker.java
import static java.util.concurrent.TimeUnit.NANOSECONDS; import com.google.common.annotations.GwtCompatible; import com.google.common.annotations.GwtIncompatible; import com.google.common.annotations.J2ktIncompatible; import com.google.common.base.Ticker; import com.google.errorprone.annotations.CanIgnoreReturnValue; import java.time.Duration; import java.util.concurrent.TimeUnit;
Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Mon Apr 14 15:16:19 GMT 2025 - 3.4K bytes - Click Count (0) -
android/guava/src/com/google/common/util/concurrent/ThreadFactoryBuilder.java
import com.google.errorprone.annotations.CanIgnoreReturnValue; import java.lang.Thread.UncaughtExceptionHandler; import java.util.Locale; import java.util.concurrent.Executors; import java.util.concurrent.ThreadFactory; import java.util.concurrent.atomic.AtomicLong; import org.jspecify.annotations.Nullable; /** * A ThreadFactory builder, providing any combination of these features: * * <ul>
Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Mon Dec 29 17:36:00 GMT 2025 - 9.2K bytes - Click Count (0) -
android/guava/src/com/google/common/util/concurrent/TimeLimiter.java
*/ package com.google.common.util.concurrent; import com.google.common.annotations.GwtIncompatible; import com.google.common.annotations.J2ktIncompatible; import com.google.errorprone.annotations.CanIgnoreReturnValue; import com.google.errorprone.annotations.DoNotMock; import java.util.concurrent.Callable; import java.util.concurrent.ExecutionException; import java.util.concurrent.TimeUnit;
Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Sat Jan 18 02:54:30 GMT 2025 - 8.2K bytes - Click Count (0) -
src/main/java/jcifs/internal/smb2/lease/DirectoryLeaseManager.java
import java.io.IOException; import java.util.ArrayList; 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 org.slf4j.Logger; import org.slf4j.LoggerFactory; import jcifs.CIFSContext; import jcifs.Configuration;
Created: Sun Apr 05 00:10:12 GMT 2026 - Last Modified: Sat Aug 23 01:47:47 GMT 2025 - 12.3K bytes - Click Count (0) -
android/guava-tests/test/com/google/common/util/concurrent/AtomicsTest.java
* limitations under the License. */ package com.google.common.util.concurrent; import static com.google.common.truth.Truth.assertThat; import static org.junit.Assert.assertThrows; import com.google.common.annotations.GwtIncompatible; import com.google.common.annotations.J2ktIncompatible; import com.google.common.testing.NullPointerTester; import java.util.concurrent.atomic.AtomicReferenceArray; import junit.framework.TestCase;
Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Thu Mar 12 17:47:10 GMT 2026 - 2.8K bytes - Click Count (0) -
compat/maven-embedder/src/main/java/org/apache/maven/cli/transfer/SimplexTransferListener.java
* under the License. */ package org.apache.maven.cli.transfer; import java.util.ArrayList; import java.util.List; import java.util.concurrent.ArrayBlockingQueue; import java.util.concurrent.ConcurrentHashMap; import java.util.concurrent.CountDownLatch; import java.util.function.Consumer; import org.eclipse.aether.transfer.AbstractTransferListener; import org.eclipse.aether.transfer.TransferCancelledException;
Created: Sun Apr 05 03:35:12 GMT 2026 - Last Modified: Fri Nov 08 08:49:11 GMT 2024 - 8.4K bytes - Click Count (0) -
okhttp-tls/src/test/java/okhttp3/tls/HandshakeCertificatesTest.kt
import assertk.assertions.matchesPredicate import java.net.InetAddress import java.net.InetSocketAddress import java.net.ServerSocket import java.security.PrivateKey import java.util.concurrent.ExecutorService import java.util.concurrent.Executors import java.util.concurrent.Future import javax.net.ServerSocketFactory import javax.net.SocketFactory import javax.net.ssl.SSLSocket import okhttp3.Handshake import okhttp3.Handshake.Companion.handshake
Created: Fri Apr 03 11:42:14 GMT 2026 - Last Modified: Tue Feb 03 08:16:15 GMT 2026 - 7.5K bytes - Click Count (0) -
android/guava-tests/test/com/google/common/cache/TestingCacheLoaders.java
import static com.google.common.base.Preconditions.checkNotNull; import static com.google.common.util.concurrent.Futures.immediateFuture; import com.google.common.annotations.GwtCompatible; import com.google.common.annotations.GwtIncompatible; import com.google.common.annotations.J2ktIncompatible; import com.google.common.util.concurrent.ListenableFuture; import com.google.errorprone.annotations.CanIgnoreReturnValue; import java.util.HashMap;
Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Mon Feb 23 13:13:59 GMT 2026 - 5.1K bytes - Click Count (0)