- Sort Score
- Result 10 results
- Languages All
Results 281 - 290 of 621 for rlock (0.05 sec)
-
android/guava-tests/test/com/google/common/util/concurrent/ExecutionSequencerTest.java
return blockingCallable.isRunning(); } }, directExecutor()); // Wait for the first task to be started in the background. It will block until we explicitly // stop it. blockingCallable.waitForStart(); // Give the second task a chance to (incorrectly) start up while the first task is running. assertThat(future2.isDone()).isFalse();
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Mon Aug 11 20:58:01 UTC 2025 - 16.1K bytes - Viewed (0) -
okhttp/src/jvmTest/kotlin/okhttp3/WebPlatformToAsciiTest.kt
/* * Copyright (C) 2023 Block, Inc. * * Licensed under the Apache License, Version 2.0 (the "License"); * you may not use this file except in compliance with the License. * You may obtain a copy of the License at * * http://www.apache.org/licenses/LICENSE-2.0 * * Unless required by applicable law or agreed to in writing, software * distributed under the License is distributed on an "AS IS" BASIS,
Registered: Fri Sep 05 11:42:10 UTC 2025 - Last Modified: Fri Dec 27 13:39:56 UTC 2024 - 3.5K bytes - Viewed (0) -
futures/failureaccess/src/com/google/common/util/concurrent/internal/InternalFutureFailureAccess.java
* then: * * <ul> * <li>{@code isDone()} must return {@code true} * <li>{@code isCancelled()} must return {@code false} * <li>{@code get()} must not block, and it must throw an {@code ExecutionException} with the * return value of this method as its cause * </ul> * * <p>This method is {@code protected} so that classes like {@code
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Sat Jan 18 02:54:30 UTC 2025 - 2.3K bytes - Viewed (0) -
cmd/admin-handlers_test.go
objLayer, err := newErasureServerPools(ctx, endpoints) if err != nil { return nil, nil, err } // Make objLayer available to all internal services via globalObjectAPI. globalObjLayerMutex.Lock() globalObjectAPI = objLayer globalObjLayerMutex.Unlock() return objLayer, erasureDirs, nil } // cmdType - Represents different service subcomands like status, stop // and restart. type cmdType int
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Fri Aug 29 02:39:48 UTC 2025 - 13.9K bytes - Viewed (0) -
src/main/webapp/css/admin/adminlte.min.css.map
-3px;\n}\n\n.user-block.user-block-sm img {\n width: 1.875rem;\n height: 1.875rem;\n}\n\n.user-block.user-block-sm .username,\n.user-block.user-block-sm .description,\n.user-block.user-block-sm .comment {\n margin-left: 40px;\n}\n\n.user-block.user-block-sm .username {\n font-size: 14px;\n}\n\n.img-sm,\n.img-md,\n.img-lg {\n float: left;\n}\n\n.img-sm {\n height: 1.875rem;\n width: 1.875rem;\n}\n\n.img-sm + .img-push {\n margin-left: 2.5rem;\n}\n\n.img-md {\n width: 3.75rem;\n height: 3.75rem;\n}\n\n.img-md...
Registered: Thu Sep 04 12:52:25 UTC 2025 - Last Modified: Sat Oct 26 01:49:09 UTC 2024 - 3.7M bytes - Viewed (1) -
cmd/metacache-server-pool.go
var funcReturnedMu sync.Mutex defer func() { funcReturnedMu.Lock() funcReturned = true funcReturnedMu.Unlock() }() // Write listing to results and saver. go func() { var returned bool for entry := range inCh { if o.shouldSkip(ctx, entry) { continue } if !returned { funcReturnedMu.Lock() returned = funcReturned funcReturnedMu.Unlock() outCh <- entry
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Mon May 26 07:06:43 UTC 2025 - 12.9K bytes - Viewed (0) -
.gitignore
/tensorflow/lite/**/coreml/**/BUILD /tensorflow/lite/**/ios/BUILD /tensorflow/lite/**/objc/BUILD /tensorflow/lite/**/swift/BUILD /tensorflow/lite/examples/ios/simple/data/*.tflite /tensorflow/lite/examples/ios/simple/data/*.txt Podfile.lock Pods
Registered: Tue Sep 09 12:39:10 UTC 2025 - Last Modified: Sat Nov 30 21:41:32 UTC 2024 - 945 bytes - Viewed (0) -
android/guava/src/com/google/common/collect/Queues.java
* Queue<E> queue = Queues.synchronizedQueue(MinMaxPriorityQueue.<E>create()); * ... * queue.add(element); // Needn't be in synchronized block * ... * synchronized (queue) { // Must synchronize on queue! * Iterator<E> i = queue.iterator(); // Must be in synchronized block * while (i.hasNext()) { * foo(i.next()); * } * } * } *
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Thu Aug 07 16:05:33 UTC 2025 - 18.3K bytes - Viewed (0) -
src/main/java/jcifs/smb1/dcerpc/rpc.java
*/ public short time_hi_and_version; /** * The high field of the clock sequence multiplexed with the variant. */ public byte clock_seq_hi_and_reserved; /** * The low field of the clock sequence. */ public byte clock_seq_low; /** * The spatially unique node identifier (6 bytes). */
Registered: Sun Sep 07 00:10:21 UTC 2025 - Last Modified: Sat Aug 16 01:32:48 UTC 2025 - 11.2K bytes - Viewed (0) -
android-test/src/test/kotlin/okhttp/android/test/DisabledInitialiserTest.kt
/* * Copyright (c) 2025 Block, Inc. * * Licensed under the Apache License, Version 2.0 (the "License"); * you may not use this file except in compliance with the License. * You may obtain a copy of the License at * * http://www.apache.org/licenses/LICENSE-2.0 * * Unless required by applicable law or agreed to in writing, software * distributed under the License is distributed on an "AS IS" BASIS,
Registered: Fri Sep 05 11:42:10 UTC 2025 - Last Modified: Sat Aug 30 16:25:39 UTC 2025 - 2.1K bytes - Viewed (0)