- Sort Score
- Result 10 results
- Languages All
Results 511 - 520 of 977 for concurrents (0.15 sec)
-
okhttp/src/main/kotlin/okhttp3/internal/ws/RealWebSocket.kt
import java.io.Closeable import java.io.IOException import java.net.ProtocolException import java.net.SocketTimeoutException import java.util.ArrayDeque import java.util.Random import java.util.concurrent.TimeUnit import java.util.concurrent.TimeUnit.MILLISECONDS import okhttp3.Call import okhttp3.Callback import okhttp3.EventListener import okhttp3.OkHttpClient import okhttp3.Protocol import okhttp3.Request import okhttp3.Response
Registered: Fri Nov 01 11:42:11 UTC 2024 - Last Modified: Mon Apr 01 14:21:25 UTC 2024 - 22.1K bytes - Viewed (0) -
internal/bucket/lifecycle/noncurrentversion.go
} *n = NoncurrentVersionTransition(val) n.set = true return nil } // IsNull returns true if NoncurrentTransition doesn't refer to any storage-class. // Note: It supports immediate transition, i.e zero noncurrent days. func (n NoncurrentVersionTransition) IsNull() bool { return n.StorageClass == "" } // Validate returns an error with wrong value func (n NoncurrentVersionTransition) Validate() error { if !n.set {
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Tue Dec 14 17:41:44 UTC 2021 - 5.3K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/helper/CrawlingConfigHelper.java
*/ package org.codelibs.fess.helper; import java.util.ArrayList; import java.util.Collections; import java.util.List; import java.util.Map; import java.util.concurrent.ConcurrentHashMap; import java.util.concurrent.TimeUnit; import java.util.regex.Pattern; import org.apache.logging.log4j.LogManager; import org.apache.logging.log4j.Logger; import org.codelibs.core.lang.StringUtil;
Registered: Thu Oct 31 13:40:30 UTC 2024 - Last Modified: Thu Feb 22 01:53:18 UTC 2024 - 11.7K bytes - Viewed (0) -
android/guava/src/com/google/common/hash/LongAddables.java
* or implied. See the License for the specific language governing permissions and limitations under * the License. */ package com.google.common.hash; import com.google.common.base.Supplier; import java.util.concurrent.atomic.AtomicLong; /** * Source of {@link LongAddable} objects that deals with GWT, Unsafe, and all that. * * @author Louis Wasserman */ @ElementTypesAreNonnullByDefault final class LongAddables {
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Tue Jan 04 17:27:14 UTC 2022 - 1.9K bytes - Viewed (0) -
guava-tests/test/com/google/common/util/concurrent/AndroidIncompatible.java
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. * See the License for the specific language governing permissions and * limitations under the License. */ package com.google.common.util.concurrent; import static java.lang.annotation.ElementType.ANNOTATION_TYPE; import static java.lang.annotation.ElementType.CONSTRUCTOR; import static java.lang.annotation.ElementType.FIELD;
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Thu Sep 15 13:47:32 UTC 2016 - 1.6K bytes - Viewed (0) -
src/main/java/jcifs/dcerpc/DcerpcConstants.java
public static final int DCERPC_PENDING_CANCEL = 0x04; /* Cancel was pending at sender */ public static final int DCERPC_RESERVED_1 = 0x08; public static final int DCERPC_CONC_MPX = 0x10; /* supports concurrent multiplexing */ public static final int DCERPC_DID_NOT_EXECUTE = 0x20; public static final int DCERPC_MAYBE = 0x40; /* `maybe' call semantics requested */
Registered: Sun Nov 03 00:10:13 UTC 2024 - Last Modified: Sun Jul 01 13:12:10 UTC 2018 - 1.7K 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) -
guava/src/com/google/common/cache/LongAddable.java
* the License. */ package com.google.common.cache; import com.google.common.annotations.GwtCompatible; /** * Abstract interface for objects that can concurrently add longs. * * @author Louis Wasserman */ @GwtCompatible @ElementTypesAreNonnullByDefault interface LongAddable { void increment(); void add(long x); long sum();
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Tue Jun 15 18:00:07 UTC 2021 - 918 bytes - Viewed (0) -
.github/workflows/go-lint.yml
name: Linters and Tests 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: build: name: Go ${{ matrix.go-version }} on ${{ matrix.os }} runs-on: ${{ matrix.os }} strategy: matrix:
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Mon Sep 16 20:46:53 UTC 2024 - 1010 bytes - Viewed (0) -
src/main/java/org/codelibs/core/beans/factory/BeanDescFactory.java
import static org.codelibs.core.collection.CollectionsUtil.putIfAbsent; import static org.codelibs.core.misc.AssertionUtil.assertArgumentNotNull; import java.util.concurrent.ConcurrentMap; import org.codelibs.core.beans.BeanDesc; import org.codelibs.core.beans.impl.BeanDescImpl; import org.codelibs.core.misc.DisposableUtil; /** * {@link BeanDesc}を生成するクラスです。 * <p>
Registered: Fri Nov 01 20:58:10 UTC 2024 - Last Modified: Thu Mar 07 01:59:08 UTC 2024 - 2.9K bytes - Viewed (0)