Search Options

Results per page
Sort
Preferred Languages
Advance

Results 321 - 330 of 977 for concurrent (0.12 sec)

  1. build-logic-commons/gradle-plugin/src/main/kotlin/gradlebuild.cache-miss-monitor.gradle.kts

    import gradlebuild.registerBuildScanInfoCollectingService
    import org.gradle.tooling.events.task.TaskOperationResult
    import org.gradle.tooling.events.task.TaskSuccessResult
    import java.io.Serializable
    import java.util.concurrent.atomic.AtomicBoolean
    
    /**
     * Register a build service that monitors a list of tasks and reports CACHE_MISS if they're actually executed.
     */
    if (buildCacheEnabled()) {
    Registered: Wed Nov 06 11:36:14 UTC 2024
    - Last Modified: Thu Mar 07 05:49:29 UTC 2024
    - 4.6K bytes
    - Viewed (0)
  2. 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.checkerframework.checker.nullness.qual.Nullable;
    
    /**
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Tue Apr 04 09:45:04 UTC 2023
    - 2.2K bytes
    - Viewed (0)
  3. src/main/java/org/codelibs/fess/rank/fusion/RankFusionProcessor.java

    import java.util.HashSet;
    import java.util.List;
    import java.util.Locale;
    import java.util.Map;
    import java.util.Set;
    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;
    import org.apache.logging.log4j.Logger;
    Registered: Thu Oct 31 13:40:30 UTC 2024
    - Last Modified: Fri Oct 11 21:20:39 UTC 2024
    - 18.3K bytes
    - Viewed (0)
  4. android/guava/src/com/google/common/util/concurrent/GwtFuturesCatchingSpecialization.java

     * the License.
     */
    
    package com.google.common.util.concurrent;
    
    import com.google.common.annotations.GwtCompatible;
    import com.google.common.annotations.J2ktIncompatible;
    
    /**
     * Hidden superclass of {@link Futures} that provides us a place to declare special GWT versions of
     * the {@link Futures#catching(ListenableFuture, Class, com.google.common.base.Function,
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Tue Apr 04 09:45:04 UTC 2023
    - 1.4K bytes
    - Viewed (0)
  5. guava-tests/test/com/google/common/collect/ReflectionFreeAssertThrows.java

    import java.nio.charset.UnsupportedCharsetException;
    import java.util.ConcurrentModificationException;
    import java.util.NoSuchElementException;
    import java.util.concurrent.CancellationException;
    import java.util.concurrent.ExecutionException;
    import java.util.concurrent.TimeoutException;
    import junit.framework.AssertionFailedError;
    import org.checkerframework.checker.nullness.qual.Nullable;
    
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Thu Oct 17 19:43:49 UTC 2024
    - 7K bytes
    - Viewed (0)
  6. guava/src/com/google/common/util/concurrent/TimeLimiter.java

    import com.google.errorprone.annotations.DoNotMock;
    import java.time.Duration;
    import java.util.concurrent.Callable;
    import java.util.concurrent.ExecutionException;
    import java.util.concurrent.TimeUnit;
    import java.util.concurrent.TimeoutException;
    import org.checkerframework.checker.nullness.qual.Nullable;
    
    /**
     * Imposes a time limit on method calls.
     *
     * @author Kevin Bourrillion
     * @author Jens Nyman
     * @since 1.0
     */
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri May 12 18:32:03 UTC 2023
    - 15.3K bytes
    - Viewed (0)
  7. guava/src/com/google/common/util/concurrent/AtomicDoubleArray.java

    import java.io.ObjectOutputStream;
    import java.io.Serializable;
    import java.util.concurrent.atomic.AtomicLongArray;
    import java.util.function.DoubleBinaryOperator;
    import java.util.function.DoubleUnaryOperator;
    
    /**
     * A {@code double} array in which elements may be updated atomically. See the {@link
     * java.util.concurrent.atomic} package specification for description of the properties of atomic
     * variables.
     *
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri Jun 14 17:55:55 UTC 2024
    - 10.3K bytes
    - Viewed (0)
  8. android/guava-tests/test/com/google/common/eventbus/EventBusTest.java

    import com.google.common.collect.ImmutableList;
    import com.google.common.collect.Lists;
    import java.util.List;
    import java.util.concurrent.ExecutorService;
    import java.util.concurrent.Executors;
    import java.util.concurrent.Future;
    import java.util.concurrent.atomic.AtomicInteger;
    import junit.framework.TestCase;
    
    /**
     * Test case for {@link EventBus}.
     *
     * @author Cliff Biffle
     */
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Thu Oct 17 15:16:45 UTC 2024
    - 11.2K bytes
    - Viewed (0)
  9. android/guava-testlib/src/com/google/common/collect/testing/testers/ReflectionFreeAssertThrows.java

    import java.nio.charset.UnsupportedCharsetException;
    import java.util.ConcurrentModificationException;
    import java.util.NoSuchElementException;
    import java.util.concurrent.CancellationException;
    import java.util.concurrent.ExecutionException;
    import java.util.concurrent.TimeoutException;
    import junit.framework.AssertionFailedError;
    import org.checkerframework.checker.nullness.qual.Nullable;
    
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Thu Oct 17 20:00:30 UTC 2024
    - 6.9K bytes
    - Viewed (0)
  10. okhttp/src/test/java/okhttp3/LoomTest.kt

     * limitations under the License.
     */
    package okhttp3
    
    import assertk.assertThat
    import assertk.assertions.isEqualTo
    import assertk.assertions.isTrue
    import java.util.concurrent.ExecutorService
    import java.util.concurrent.Executors
    import mockwebserver3.MockResponse
    import mockwebserver3.MockWebServer
    import okhttp3.testing.PlatformRule
    import org.junit.jupiter.api.BeforeEach
    import org.junit.jupiter.api.Test
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon Jan 08 01:13:22 UTC 2024
    - 2K bytes
    - Viewed (0)
Back to top