Search Options

Results per page
Sort
Preferred Languages
Advance

Results 231 - 240 of 966 for concurrency (0.09 sec)

  1. android/guava/src/com/google/common/util/concurrent/FakeTimeLimiter.java

    import com.google.errorprone.annotations.CanIgnoreReturnValue;
    import java.util.concurrent.Callable;
    import java.util.concurrent.ExecutionException;
    import java.util.concurrent.TimeUnit;
    import org.checkerframework.checker.nullness.qual.Nullable;
    
    /**
     * A TimeLimiter implementation which actually does not attempt to limit time at all. This may be
     * desirable to use in some unit tests. More importantly, attempting to debug a call which is
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Thu Dec 14 20:35:03 UTC 2023
    - 3.5K bytes
    - Viewed (0)
  2. okhttp/src/main/kotlin/okhttp3/internal/connection/FastFallbackExchangeFinder.kt

     * limitations under the License.
     */
    package okhttp3.internal.connection
    
    import java.io.IOException
    import java.util.concurrent.CopyOnWriteArrayList
    import java.util.concurrent.LinkedBlockingDeque
    import java.util.concurrent.TimeUnit
    import okhttp3.internal.concurrent.Task
    import okhttp3.internal.concurrent.TaskRunner
    import okhttp3.internal.connection.RoutePlanner.ConnectResult
    import okhttp3.internal.connection.RoutePlanner.Plan
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon Jan 08 01:13:22 UTC 2024
    - 5.8K bytes
    - Viewed (0)
  3. guava-tests/test/com/google/common/util/concurrent/ListenableFutureTester.java

    import static junit.framework.Assert.fail;
    import static org.junit.Assert.assertThrows;
    
    import java.util.concurrent.CancellationException;
    import java.util.concurrent.CountDownLatch;
    import java.util.concurrent.ExecutionException;
    import java.util.concurrent.ExecutorService;
    import java.util.concurrent.Executors;
    import org.checkerframework.checker.nullness.qual.Nullable;
    
    /**
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri Oct 18 22:10:29 UTC 2024
    - 3.3K bytes
    - Viewed (0)
  4. guava-tests/test/com/google/common/util/concurrent/CycleDetectingLockFactoryTest.java

     */
    
    package com.google.common.util.concurrent;
    
    import static com.google.common.truth.Truth.assertThat;
    import static java.util.concurrent.TimeUnit.MINUTES;
    import static org.junit.Assert.assertThrows;
    
    import com.google.common.base.Joiner;
    import com.google.common.util.concurrent.CycleDetectingLockFactory.Policies;
    import com.google.common.util.concurrent.CycleDetectingLockFactory.Policy;
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri Oct 18 22:10:29 UTC 2024
    - 16.1K bytes
    - Viewed (0)
  5. android/guava-tests/test/com/google/common/util/concurrent/CycleDetectingLockFactoryTest.java

     */
    
    package com.google.common.util.concurrent;
    
    import static com.google.common.truth.Truth.assertThat;
    import static java.util.concurrent.TimeUnit.MINUTES;
    import static org.junit.Assert.assertThrows;
    
    import com.google.common.base.Joiner;
    import com.google.common.util.concurrent.CycleDetectingLockFactory.Policies;
    import com.google.common.util.concurrent.CycleDetectingLockFactory.Policy;
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri Oct 18 22:10:29 UTC 2024
    - 16.1K bytes
    - Viewed (0)
  6. guava-tests/test/com/google/common/util/concurrent/ListenableFutureTaskTest.java

     */
    
    package com.google.common.util.concurrent;
    
    import static com.google.common.util.concurrent.MoreExecutors.directExecutor;
    import static java.util.concurrent.TimeUnit.SECONDS;
    import static org.junit.Assert.assertThrows;
    
    import java.util.concurrent.Callable;
    import java.util.concurrent.CountDownLatch;
    import java.util.concurrent.ExecutionException;
    import java.util.concurrent.ExecutorService;
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri Oct 18 22:10:29 UTC 2024
    - 4.7K bytes
    - Viewed (0)
  7. RELEASE.md

    *   `tf.config.experimental_list_devices` has been removed, please use
        `tf.config.list_logical_devices`.
    
    ## Bug Fixes and Other Changes
    
    *   `tf.data`
        *   Fixes concurrency issue with `tf.data.experimental.parallel_interleave`
            with `sloppy=True`.
        *   Add `tf.data.experimental.dense_to_ragged_batch()`.
        *   Extend `tf.data` parsing ops to support `RaggedTensors`.
    Registered: Tue Nov 05 12:39:12 UTC 2024
    - Last Modified: Tue Oct 22 14:33:53 UTC 2024
    - 735.3K bytes
    - Viewed (0)
  8. guava-gwt/src/com/google/common/base/Base.gwt.xml

        util.concurrent tests under Guava.
    
        The problem is that GWT responds poorly to two .gwt.xml files in the same
        Java package; see
        https://groups.google.com/g/google-web-toolkit-contributors/c/CqYH59Dt_rQ/m/uVGW1QdUsXUJ
        for details.
    
        The summary is that it ignores one file in favor of the other.
        util.concurrent, like nearly all our packages, has two .gwt.xml files: one
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri Jul 19 16:02:36 UTC 2024
    - 1.4K bytes
    - Viewed (0)
  9. CHANGELOG/CHANGELOG-1.27.md

    - Update kube-apiserver's priority & fairness work estimator such that 'max seats' is MIN(0.15 x nominalCL, nominalCL / handSize)
      
      This fixes a bug where clients with requests using hand size x max seats greater than the nominal concurrency limit can starve other requests in the same priority level. ([#118601](https://github.com/kubernetes/kubernetes/pull/118601), [@andrewsykim](https://github.com/andrewsykim)) [SIG API Machinery]
    
    ## Dependencies
    
    Registered: Fri Nov 01 09:05:11 UTC 2024
    - Last Modified: Wed Jul 17 07:48:22 UTC 2024
    - 466.3K bytes
    - Viewed (1)
  10. guava-tests/test/com/google/common/util/concurrent/WrappingExecutorServiceTest.java

    import com.google.common.collect.Lists;
    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;
    
    /**
     * Test for {@link WrappingExecutorService}
     *
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri Oct 18 22:10:29 UTC 2024
    - 9.9K bytes
    - Viewed (0)
Back to top