Search Options

Results per page
Sort
Preferred Languages
Advance

Results 261 - 270 of 958 for concurrence (0.06 sec)

  1. android/guava-tests/test/com/google/common/collect/ForwardingConcurrentMapTest.java

     * See the License for the specific language governing permissions and
     * limitations under the License.
     */
    
    package com.google.common.collect;
    
    import java.util.concurrent.ConcurrentHashMap;
    import java.util.concurrent.ConcurrentMap;
    import junit.framework.TestCase;
    
    /**
     * Tests for {@link ForwardingConcurrentMap}.
     *
     * @author Jared Levy
     */
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Mon Dec 04 17:37:03 UTC 2017
    - 2.4K bytes
    - Viewed (0)
  2. android/guava-tests/test/com/google/common/util/concurrent/InterruptionUtil.java

     */
    
    package com.google.common.util.concurrent;
    
    import static com.google.common.base.Preconditions.checkNotNull;
    import static java.util.concurrent.TimeUnit.MILLISECONDS;
    import static java.util.concurrent.TimeUnit.NANOSECONDS;
    import static junit.framework.Assert.fail;
    
    import com.google.common.testing.TearDown;
    import com.google.common.testing.TearDownAccepter;
    import java.util.concurrent.TimeUnit;
    import java.util.logging.Logger;
    
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Mon Dec 04 17:37:03 UTC 2017
    - 4.4K bytes
    - Viewed (0)
  3. 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 com.google.common.collect.Lists;
    import java.util.List;
    import java.util.concurrent.Executor;
    import java.util.concurrent.TimeoutException;
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri Oct 18 22:10:29 UTC 2024
    - 7.5K bytes
    - Viewed (0)
  4. src/main/java/org/codelibs/fess/helper/ProcessHelper.java

     */
    package org.codelibs.fess.helper;
    
    import java.io.IOException;
    import java.io.OutputStream;
    import java.util.List;
    import java.util.Set;
    import java.util.concurrent.ConcurrentHashMap;
    import java.util.concurrent.CountDownLatch;
    import java.util.concurrent.TimeUnit;
    import java.util.function.Consumer;
    
    import org.apache.commons.io.IOUtils;
    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
    - 6.4K bytes
    - Viewed (0)
  5. okhttp-tls/src/test/java/okhttp3/tls/HandshakeCertificatesTest.kt

    import assertk.assertions.matchesPredicate
    import java.net.InetAddress
    import java.net.InetSocketAddress
    import java.net.ServerSocket
    import java.security.PrivateKey
    import java.util.concurrent.ExecutorService
    import java.util.concurrent.Executors
    import java.util.concurrent.Future
    import javax.net.ServerSocketFactory
    import javax.net.SocketFactory
    import javax.net.ssl.SSLSocket
    import okhttp3.Handshake
    import okhttp3.Handshake.Companion.handshake
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Thu Apr 11 22:09:35 UTC 2024
    - 7.1K bytes
    - Viewed (0)
  6. src/test/java/org/codelibs/fess/suggest/concurrent/DeferredTest.java

     * governing permissions and limitations under the License.
     */
    package org.codelibs.fess.suggest.concurrent;
    
    import static org.junit.Assert.assertEquals;
    import static org.junit.Assert.assertTrue;
    import static org.junit.Assert.fail;
    
    import java.util.Collections;
    import java.util.concurrent.CountDownLatch;
    import java.util.concurrent.TimeUnit;
    
    import org.codelibs.fess.suggest.exception.SuggesterException;
    Registered: Fri Nov 08 09:08:12 UTC 2024
    - Last Modified: Thu Feb 22 01:36:54 UTC 2024
    - 4.8K bytes
    - Viewed (0)
  7. 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)
  8. cmd/admin-handlers.go

    	// if we do run out of capacity, make sure to turn-off autotuning
    	// in such situations.
    	if autotune {
    		newConcurrent := concurrent + (concurrent+1)/2
    		autoTunedCapacityNeeded := uint64(newConcurrent * size)
    		if capacity < autoTunedCapacityNeeded {
    			// Turn-off auto-tuning if next possible concurrency would reach beyond disk capacity.
    			return true, false, ""
    		}
    	}
    
    	return true, autotune, ""
    }
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Oct 04 11:32:32 UTC 2024
    - 99.7K bytes
    - Viewed (0)
  9. 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 Nov 01 11:42:11 UTC 2024
    - Last Modified: Wed Dec 20 23:27:07 UTC 2023
    - 1.5K bytes
    - Viewed (0)
  10. .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
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sun Jun 09 09:13:09 UTC 2024
    - 551 bytes
    - Viewed (0)
Back to top