- Sort Score
- Result 10 results
- Languages All
Results 81 - 90 of 1,073 for concurrency (1 sec)
-
guava/src/com/google/common/collect/Interners.java
*/ @CanIgnoreReturnValue @GwtIncompatible("java.lang.ref.WeakReference") public InternerBuilder weak() { this.strong = false; return this; } /** * Sets the concurrency level that will be used by the to-be-built {@link Interner}. * * @see MapMaker#concurrencyLevel(int) */ @CanIgnoreReturnValue public InternerBuilder concurrencyLevel(int concurrencyLevel) {Registered: Fri Dec 26 12:43:10 UTC 2025 - Last Modified: Thu Jul 17 15:26:41 UTC 2025 - 6K bytes - Viewed (0) -
cmd/warm-backend-azure.go
azMeta := map[string]*string{} for k, v := range meta { azMeta[k] = to.Ptr(v) } resp, err := az.clnt.UploadStream(ctx, az.Bucket, az.getDest(object), io.LimitReader(r, length), &azblob.UploadStreamOptions{ Concurrency: 4, AccessTier: az.tier(), // set tier if specified Metadata: azMeta, }) if err != nil { return "", azureToObjectError(err, az.Bucket, az.getDest(object)) } vid := "" if resp.VersionID != nil {
Registered: Sun Dec 28 19:28:13 UTC 2025 - Last Modified: Thu Oct 31 22:10:24 UTC 2024 - 7K bytes - Viewed (0) -
src/main/java/jcifs/internal/smb2/Smb2SigningDigest.java
if (offset + SIGNATURE_OFFSET + SIGNATURE_LENGTH > data.length) { throw new IllegalArgumentException("Signature field exceeds data buffer size"); } // Use fine-grained locking for better concurrency this.signingLock.lock(); try { if (this.closed) { throw new IllegalStateException("SigningDigest is closed"); } // zero out signature field
Registered: Sat Dec 20 13:44:44 UTC 2025 - Last Modified: Sat Aug 30 05:58:03 UTC 2025 - 9.9K bytes - Viewed (0) -
README.md
- **Logging Abstraction** (`org.codelibs.core.log`) - Flexible logging system supporting JCL (Jakarta Commons Logging) and JUL (Java Util Logging) - **Concurrent Utilities** (`org.codelibs.core.concurrent`) - Thread-safe collections and concurrency helpers using modern concurrent APIs - **Crypto & Security** (`org.codelibs.core.crypto`, `org.codelibs.core.security`) - Basic cryptographic utilities, message digest operations, and secure random generation
Registered: Sat Dec 20 08:55:33 UTC 2025 - Last Modified: Sun Aug 31 02:56:02 UTC 2025 - 12.7K bytes - Viewed (0) -
docs/en/docs/deployment/manually.md
/// tip By adding the `standard`, Uvicorn will install and use some recommended extra dependencies. That including `uvloop`, the high-performance drop-in replacement for `asyncio`, that provides the big concurrency performance boost. When you install FastAPI with something like `pip install "fastapi[standard]"` you already get `uvicorn[standard]` as well. /// ## Run the Server Program { #run-the-server-program }
Registered: Sun Dec 28 07:19:09 UTC 2025 - Last Modified: Sat Oct 11 17:48:49 UTC 2025 - 6.9K bytes - Viewed (0) -
tests/test_dependency_wrapped.py
import inspect import sys from collections.abc import AsyncGenerator, Generator from functools import wraps import pytest from fastapi import Depends, FastAPI from fastapi.concurrency import iterate_in_threadpool, run_in_threadpool from fastapi.testclient import TestClient if sys.version_info >= (3, 13): # pragma: no cover from inspect import iscoroutinefunction else: # pragma: no cover from asyncio import iscoroutinefunction
Registered: Sun Dec 28 07:19:09 UTC 2025 - Last Modified: Wed Dec 17 21:25:59 UTC 2025 - 11.2K bytes - Viewed (0) -
docs/tr/docs/async.md
# Concurrency ve async / await *path operasyon fonksiyonu* için `async def `sözdizimi, asenkron kod, eşzamanlılık ve paralellik hakkında bazı ayrıntılar. ## Aceleniz mi var? <abbr title="too long; didn't read"><strong>TL;DR:</strong></abbr> Eğer `await` ile çağrılması gerektiğini belirten üçüncü taraf kütüphaneleri kullanıyorsanız, örneğin: ```Python results = await some_library() ```
Registered: Sun Dec 28 07:19:09 UTC 2025 - Last Modified: Sun Aug 31 09:56:21 UTC 2025 - 21.8K bytes - Viewed (0) -
src/test/java/jcifs/internal/smb2/ServerMessageBlock2ResponseTest.java
assertTrue(exception.getMessage().contains("Signature verification failed")); } } @Nested @DisplayName("Concurrency Tests") class ConcurrencyTests { @Test @DisplayName("Should handle concurrent received notifications") void testConcurrentReceived() throws InterruptedException { int threadCount = 10;Registered: Sat Dec 20 13:44:44 UTC 2025 - Last Modified: Thu Aug 14 05:31:44 UTC 2025 - 19.3K bytes - Viewed (0) -
fastapi/dependencies/utils.py
is_uploadfile_sequence_annotation, lenient_issubclass, sequence_types, serialize_sequence_value, value_is_sequence, ) from fastapi.background import BackgroundTasks from fastapi.concurrency import ( asynccontextmanager, contextmanager_in_threadpool, ) from fastapi.dependencies.models import Dependant from fastapi.exceptions import DependencyScopeError from fastapi.logger import loggerRegistered: Sun Dec 28 07:19:09 UTC 2025 - Last Modified: Sat Dec 27 12:54:56 UTC 2025 - 37.6K bytes - Viewed (3) -
.github/workflows/maven.yml
# under the License. name: Java CI on: push: branches: [ master ] pull_request: branches: [ master ] # allow single build per branch or PR concurrency: group: ${{ github.workflow }}-${{ github.ref }} cancel-in-progress: true # clear all permissions for GITHUB_TOKEN permissions: {} env: MIMIR_VERSION: 0.10.6 MIMIR_BASEDIR: ~/.mimirRegistered: Sun Dec 28 03:35:09 UTC 2025 - Last Modified: Tue Dec 16 04:24:24 UTC 2025 - 12.2K bytes - Viewed (0)