- Sort Score
- Num 10 results
- Language All
Results 211 - 220 of 1,064 for concurrence (0.11 seconds)
-
guava-tests/test/com/google/common/util/concurrent/ListenableFutureTaskTest.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.Executors.newCachedThreadPool; import static java.util.concurrent.TimeUnit.SECONDS; import static org.junit.Assert.assertThrows; import java.util.concurrent.Callable; import java.util.concurrent.CountDownLatch;
Created: Fri Dec 26 12:43:10 GMT 2025 - Last Modified: Thu Dec 11 21:00:51 GMT 2025 - 4.8K bytes - Click Count (0) -
src/test/java/jcifs/util/SecureKeyManagerTest.java
import java.security.GeneralSecurityException; import java.security.SecureRandom; import java.util.Arrays; 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 javax.crypto.SecretKey; import org.junit.jupiter.api.AfterEach;
Created: Sat Dec 20 13:44:44 GMT 2025 - Last Modified: Sat Aug 30 05:58:03 GMT 2025 - 14.2K bytes - Click Count (0) -
guava-tests/test/com/google/common/util/concurrent/WrappingExecutorServiceTest.java
import java.util.ArrayList; import java.util.Collection; import java.util.List; import java.util.concurrent.Callable; import java.util.concurrent.ExecutionException; import java.util.concurrent.ExecutorService; import java.util.concurrent.Future; import java.util.concurrent.TimeUnit; import java.util.concurrent.TimeoutException; import junit.framework.TestCase; import org.jspecify.annotations.NullUnmarked; /**
Created: Fri Dec 26 12:43:10 GMT 2025 - Last Modified: Mon Jul 14 14:44:08 GMT 2025 - 9.9K bytes - Click Count (0) -
.github/workflows/helm-lint.yml
name: Helm Chart linting on: pull_request: branches: - master # This ensures that previous jobs for the PR are canceled when the PR is # updated. concurrency: group: ${{ github.workflow }}-${{ github.head_ref }} cancel-in-progress: true permissions: contents: read jobs: release: runs-on: ubuntu-latest steps: - name: Checkout uses: actions/checkout@v4Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Sun Jun 09 09:13:09 GMT 2024 - 551 bytes - Click Count (0) -
android/guava/src/com/google/common/collect/Queues.java
import java.util.Queue; import java.util.concurrent.ArrayBlockingQueue; import java.util.concurrent.BlockingQueue; import java.util.concurrent.ConcurrentLinkedQueue; import java.util.concurrent.LinkedBlockingDeque; import java.util.concurrent.LinkedBlockingQueue; import java.util.concurrent.PriorityBlockingQueue; import java.util.concurrent.SynchronousQueue; import java.util.concurrent.TimeUnit; import org.jspecify.annotations.Nullable;
Created: Fri Dec 26 12:43:10 GMT 2025 - Last Modified: Tue Nov 04 17:24:58 GMT 2025 - 18.2K bytes - Click Count (0) -
guava/src/com/google/common/cache/ForwardingCache.java
import com.google.common.base.Preconditions; import com.google.common.collect.ForwardingObject; import com.google.common.collect.ImmutableMap; import java.util.Map; import java.util.concurrent.Callable; import java.util.concurrent.ConcurrentMap; import java.util.concurrent.ExecutionException; import org.jspecify.annotations.Nullable; /** * A cache which forwards all its method calls to another cache. Subclasses should override one or
Created: Fri Dec 26 12:43:10 GMT 2025 - Last Modified: Sat Jan 18 02:54:30 GMT 2025 - 3.6K bytes - Click Count (0) -
okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/connection/RealCall.kt
import java.net.Socket import java.util.concurrent.CopyOnWriteArrayList import java.util.concurrent.ExecutorService import java.util.concurrent.RejectedExecutionException import java.util.concurrent.TimeUnit.MILLISECONDS import java.util.concurrent.atomic.AtomicBoolean import java.util.concurrent.atomic.AtomicInteger import java.util.concurrent.atomic.AtomicReference import java.util.concurrent.atomic.AtomicReferenceFieldUpdater
Created: Fri Dec 26 11:42:13 GMT 2025 - Last Modified: Wed Nov 05 18:28:35 GMT 2025 - 19.7K bytes - Click Count (0) -
src/test/java/jcifs/util/ResourceManagerTest.java
import static org.junit.jupiter.api.Assertions.assertThrows; import static org.junit.jupiter.api.Assertions.assertTrue; import java.util.Map; import java.util.concurrent.TimeUnit; import java.util.concurrent.atomic.AtomicBoolean; import org.junit.jupiter.api.BeforeEach; import org.junit.jupiter.api.DisplayName; import org.junit.jupiter.api.Test; import org.junit.jupiter.api.Timeout; /**
Created: Sat Dec 20 13:44:44 GMT 2025 - Last Modified: Sat Aug 30 05:58:03 GMT 2025 - 8.9K bytes - Click Count (0) -
src/main/java/org/codelibs/fess/rank/fusion/RankFusionProcessor.java
import java.util.List; import java.util.Locale; import java.util.Map; import java.util.Set; import java.util.concurrent.CopyOnWriteArrayList; import java.util.concurrent.ExecutionException; import java.util.concurrent.ExecutorService; import java.util.concurrent.Executors; import java.util.concurrent.Future; import java.util.concurrent.TimeUnit; import java.util.stream.Collectors; import org.apache.logging.log4j.LogManager;
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) -
guava/src/com/google/common/util/concurrent/AbstractTransformFuture.java
* the License. */ package com.google.common.util.concurrent; import static com.google.common.base.Preconditions.checkNotNull; import static com.google.common.util.concurrent.Futures.getDone; import static com.google.common.util.concurrent.MoreExecutors.rejectionPropagatingExecutor; import static com.google.common.util.concurrent.Platform.restoreInterruptIfIsInterruptedException;
Created: Fri Dec 26 12:43:10 GMT 2025 - Last Modified: Thu Feb 20 18:03:37 GMT 2025 - 10.8K bytes - Click Count (0)