- Sort Score
- Result 10 results
- Languages All
Results 331 - 340 of 1,082 for concurrents (0.07 sec)
-
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;
Registered: Fri Dec 26 12:43:10 UTC 2025 - Last Modified: Mon Apr 14 15:16:19 UTC 2025 - 3.4K bytes - Viewed (0) -
src/test/java/jcifs/smb1/smb1/BufferCacheSecurityTest.java
import static org.junit.jupiter.api.Assertions.assertTrue; import java.util.ArrayList; import java.util.List; import java.util.concurrent.CountDownLatch; import java.util.concurrent.ExecutorService; import java.util.concurrent.Executors; import java.util.concurrent.TimeUnit; import java.util.concurrent.atomic.AtomicInteger; import org.junit.jupiter.api.Test; /**
Registered: Sat Dec 20 13:44:44 UTC 2025 - Last Modified: Sun Aug 31 08:00:57 UTC 2025 - 9.6K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/util/concurrent/StripedTest.java
import java.util.HashMap; import java.util.List; import java.util.Map; import java.util.Set; import java.util.concurrent.Semaphore; import java.util.concurrent.locks.Lock; import java.util.concurrent.locks.ReadWriteLock; import java.util.concurrent.locks.ReentrantLock; import java.util.concurrent.locks.ReentrantReadWriteLock; import junit.framework.TestCase; import org.jspecify.annotations.NullUnmarked; /**
Registered: Fri Dec 26 12:43:10 UTC 2025 - Last Modified: Tue Oct 28 18:19:59 UTC 2025 - 8.5K bytes - Viewed (0) -
guava-tests/test/com/google/common/util/concurrent/StripedTest.java
import java.util.HashMap; import java.util.List; import java.util.Map; import java.util.Set; import java.util.concurrent.Semaphore; import java.util.concurrent.locks.Lock; import java.util.concurrent.locks.ReadWriteLock; import java.util.concurrent.locks.ReentrantLock; import java.util.concurrent.locks.ReentrantReadWriteLock; import junit.framework.TestCase; import org.jspecify.annotations.NullUnmarked; /**
Registered: Fri Dec 26 12:43:10 UTC 2025 - Last Modified: Tue Oct 28 18:19:59 UTC 2025 - 8.5K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/ForwardingListeningExecutorService.java
* the License. */ package com.google.common.util.concurrent; import com.google.common.annotations.GwtIncompatible; import com.google.common.annotations.J2ktIncompatible; import java.util.concurrent.Callable; import org.jspecify.annotations.Nullable; /**
Registered: Fri Dec 26 12:43:10 UTC 2025 - Last Modified: Sun Dec 22 03:38:46 UTC 2024 - 2.2K bytes - Viewed (0) -
okhttp-testing-support/src/main/kotlin/okhttp3/internal/duplex/AsyncRequestBody.kt
* See the License for the specific language governing permissions and * limitations under the License. */ package okhttp3.internal.duplex import java.util.concurrent.BlockingQueue import java.util.concurrent.LinkedBlockingQueue import java.util.concurrent.TimeUnit.SECONDS import okhttp3.MediaType import okhttp3.RequestBody import okio.BufferedSink import org.junit.jupiter.api.Assertions.assertTrue
Registered: Fri Dec 26 11:42:13 UTC 2025 - Last Modified: Wed Mar 19 19:25:20 UTC 2025 - 1.5K bytes - Viewed (0) -
docs/bucket/lifecycle/README.md
``` mc ilm rule add --noncurrent-expire-days 365 --prefix "user-uploads/" myminio/mydata ``` ### 3.2 Automatic removal of noncurrent versions keeping only most recent ones after noncurrent days It is possible to configure automatic removal of older noncurrent versions keeping only the most recent `N` using `NewerNoncurrentVersions`.
Registered: Sun Dec 28 19:28:13 UTC 2025 - Last Modified: Tue Aug 12 18:20:36 UTC 2025 - 9.1K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/util/concurrent/AbstractIdleServiceTest.java
*/ package com.google.common.util.concurrent; import static com.google.common.truth.Truth.assertThat; import static com.google.common.util.concurrent.MoreExecutors.directExecutor; import static java.util.concurrent.TimeUnit.MILLISECONDS; import static org.junit.Assert.assertThrows; import java.util.ArrayList; import java.util.List; import java.util.concurrent.Executor; import java.util.concurrent.TimeoutException;
Registered: Fri Dec 26 12:43:10 UTC 2025 - Last Modified: Tue May 13 18:46:00 UTC 2025 - 7.5K bytes - Viewed (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;
Registered: Sat Dec 20 13:44:44 UTC 2025 - Last Modified: Thu Aug 21 11:13:46 UTC 2025 - 11.6K bytes - Viewed (0) -
okhttp/src/jvmTest/kotlin/okhttp3/internal/http/ThreadInterruptTest.kt
import assertk.fail import java.io.IOException import java.net.ServerSocket import java.net.Socket import java.net.SocketException import java.util.concurrent.CompletableFuture import java.util.concurrent.RejectedExecutionException import java.util.concurrent.TimeUnit import kotlin.test.assertFailsWith import okhttp3.Call import okhttp3.Callback import okhttp3.DelegatingServerSocketFactory
Registered: Fri Dec 26 11:42:13 UTC 2025 - Last Modified: Tue Nov 04 18:33:48 UTC 2025 - 6.4K bytes - Viewed (0)