Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 211 - 220 of 1,064 for concurrence (0.11 seconds)

  1. 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)
  2. 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)
  3. 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)
  4. .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@v4
    
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Sun Jun 09 09:13:09 GMT 2024
    - 551 bytes
    - Click Count (0)
  5. 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)
  6. 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)
  7. 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)
  8. 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)
  9. 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)
  10. 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)
Back to Top