- Sort Score
- Result 10 results
- Languages All
Results 621 - 630 of 1,022 for concurrency (0.04 sec)
-
guava/src/com/google/common/collect/JdkBackedImmutableMultiset.java
import com.google.common.annotations.GwtIncompatible; import com.google.common.annotations.J2ktIncompatible; import com.google.common.primitives.Ints; import com.google.errorprone.annotations.concurrent.LazyInit; import java.util.Collection; import java.util.Map; import org.jspecify.annotations.Nullable; /** * An implementation of ImmutableMultiset backed by a JDK Map and a list of entries. Used to protect
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Tue Apr 08 13:05:15 UTC 2025 - 3.2K bytes - Viewed (0) -
src/main/java/jcifs/internal/smb2/rdma/tcp/TcpMemoryRegion.java
* Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA 02111-1307 USA */ package jcifs.internal.smb2.rdma.tcp; import java.nio.ByteBuffer; import java.util.EnumSet; import java.util.concurrent.atomic.AtomicInteger; import jcifs.internal.smb2.rdma.RdmaAccess; import jcifs.internal.smb2.rdma.RdmaMemoryRegion; /** * TCP memory region implementation. *
Registered: Sun Sep 07 00:10:21 UTC 2025 - Last Modified: Sat Aug 23 05:11:12 UTC 2025 - 2.1K bytes - Viewed (0) -
android/guava/src/com/google/common/cache/RemovalListener.java
* due to eviction resulting from timed expiration, exceeding a maximum size, or garbage collection. * * <p>An instance may be called concurrently by multiple threads to process different entries. * Implementations of this interface should avoid performing blocking calls or synchronizing on * shared resources. *
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Sat Dec 21 03:10:51 UTC 2024 - 2K bytes - Viewed (0) -
cmd/peer-rest-common.go
peerRESTIsGroup = "is-group" peerRESTSignal = "signal" peerRESTSubSys = "sub-sys" peerRESTProfiler = "profiler" peerRESTSize = "size" peerRESTConcurrent = "concurrent" peerRESTDuration = "duration" peerRESTStorageClass = "storage-class" peerRESTEnableSha256 = "enableSha256" peerRESTEnableMultipart = "enableMultipart" peerRESTAccessKey = "access-key"
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Mon Sep 09 16:58:30 UTC 2024 - 3K bytes - Viewed (0) -
docs/smb3-features/03-multi-channel-design.md
return Math.max(0, score); } } ``` ### 4.3 Channel Manager ```java package jcifs.internal.smb2.multichannel; import java.util.*; import java.util.concurrent.*; import java.util.concurrent.atomic.AtomicInteger; public class ChannelManager { private final CIFSContext context; private final SmbSession session; private final Map<String, ChannelInfo> channels;
Registered: Sun Sep 07 00:10:21 UTC 2025 - Last Modified: Sat Aug 16 02:53:50 UTC 2025 - 39.6K bytes - Viewed (0) -
docs/multi-tenancy/README.md
 ## 2. Distributed Deployment To host multiple tenants in a distributed environment, run several distributed MinIO Server instances concurrently. ### 2.1 Host Multiple Tenants on Multiple Drives (Erasure Code) Use the following commands to host 3 tenants on a 4-node distributed configuration: ```sh export MINIO_ROOT_USER=<TENANT1_ACCESS_KEY>
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Tue Aug 12 18:20:36 UTC 2025 - 3.1K bytes - Viewed (0) -
okhttp/src/jvmTest/kotlin/okhttp3/RecordingCallback.kt
* See the License for the specific language governing permissions and * limitations under the License. */ package okhttp3 import java.io.IOException import java.util.concurrent.TimeUnit /** * Records received HTTP responses so they can be later retrieved by tests. */ class RecordingCallback : Callback { private val responses = mutableListOf<RecordedResponse>() @Synchronized
Registered: Fri Sep 05 11:42:10 UTC 2025 - Last Modified: Fri Dec 27 13:39:56 UTC 2024 - 2.1K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/LazyLogger.java
* or implied. See the License for the specific language governing permissions and limitations under * the License. */ package com.google.common.util.concurrent; import com.google.common.annotations.GwtCompatible; import java.util.logging.Logger; import org.jspecify.annotations.Nullable; /** A holder for a {@link Logger} that is initialized only when requested. */
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Sun Dec 22 03:38:46 UTC 2024 - 1.9K bytes - Viewed (0) -
okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/http2/Http2Writer.kt
*/ package okhttp3.internal.http2 import java.io.Closeable import java.io.IOException import java.util.logging.Level.FINE import java.util.logging.Logger import okhttp3.internal.concurrent.Lockable import okhttp3.internal.concurrent.withLock import okhttp3.internal.format import okhttp3.internal.http2.Http2.CONNECTION_PREFACE import okhttp3.internal.http2.Http2.FLAG_ACK import okhttp3.internal.http2.Http2.FLAG_END_HEADERS
Registered: Fri Sep 05 11:42:10 UTC 2025 - Last Modified: Wed May 28 23:28:25 UTC 2025 - 11K bytes - Viewed (0) -
android/guava-testlib/src/com/google/common/collect/testing/TestsForMapsInJavaUtil.java
import java.util.Hashtable; import java.util.LinkedHashMap; import java.util.Map; import java.util.Map.Entry; import java.util.SortedMap; import java.util.TreeMap; import java.util.concurrent.ConcurrentHashMap; import java.util.concurrent.ConcurrentSkipListMap; import junit.framework.Test; import junit.framework.TestSuite; /** * Generates a test suite covering the {@link Map} implementations in the {@link java.util} package.
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Wed Feb 12 16:28:01 UTC 2025 - 17.2K bytes - Viewed (0)