- Sort Score
- Result 10 results
- Languages All
Results 261 - 270 of 958 for concurrence (0.06 sec)
-
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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) -
.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)