- Sort Score
- Result 10 results
- Languages All
Results 41 - 50 of 1,437 for clocks (0.19 sec)
-
platforms/core-runtime/launcher/src/main/java/org/gradle/launcher/daemon/server/DefaultDaemonConnection.java
import java.util.LinkedList; import java.util.concurrent.BlockingQueue; import java.util.concurrent.LinkedBlockingQueue; import java.util.concurrent.TimeUnit; import java.util.concurrent.locks.Condition; import java.util.concurrent.locks.Lock; import java.util.concurrent.locks.ReentrantLock; public class DefaultDaemonConnection implements DaemonConnection { private static final Logger LOGGER = LoggerFactory.getLogger(DefaultDaemonConnection.class);
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Wed May 15 19:51:37 UTC 2024 - 16K bytes - Viewed (0) -
src/runtime/mspanset.go
// which claimed the last slot in the block, we're just the last one // to finish popping. if block.popped.Add(1) == spanSetBlockEntries { // Clear the block's pointer. blockp.StoreNoWB(nil) // Return the block to the block pool. spanSetBlockPool.free(block) } return s } // reset resets a spanSet which is empty. It will also clean up // any left over blocks. // // Throws if the buf is not empty.
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Mar 25 19:53:03 UTC 2024 - 13.1K bytes - Viewed (0) -
platforms/core-runtime/messaging/src/main/java/org/gradle/internal/dispatch/AsyncDispatch.java
import java.util.HashMap; import java.util.LinkedList; import java.util.Map; import java.util.concurrent.Executor; import java.util.concurrent.locks.Condition; import java.util.concurrent.locks.Lock; import java.util.concurrent.locks.ReentrantLock; /** * <p>A {@link Dispatch} implementation which delivers messages asynchronously. Calls to
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Mon Dec 11 13:37:56 UTC 2023 - 6.7K bytes - Viewed (0) -
platforms/core-runtime/launcher/src/main/java/org/gradle/launcher/daemon/server/DefaultIncomingConnectionHandler.java
import java.util.Arrays; import java.util.HashSet; import java.util.Set; import java.util.concurrent.TimeUnit; import java.util.concurrent.locks.Condition; import java.util.concurrent.locks.Lock; import java.util.concurrent.locks.ReentrantLock; public class DefaultIncomingConnectionHandler implements IncomingConnectionHandler, Stoppable {
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Sep 22 09:29:13 UTC 2023 - 7K bytes - Viewed (0) -
guava/src/com/google/common/util/concurrent/Monitor.java
} final ReentrantLock lock = this.lock; lock.lock(); boolean satisfied = false; try { return satisfied = guard.isSatisfied(); } finally { if (!satisfied) { lock.unlock(); } } } /** * Enters this monitor if the guard is satisfied. Blocks at most the given time acquiring the * lock, but does not wait for the guard to be satisfied.
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Mon Dec 04 18:22:01 UTC 2023 - 42.5K bytes - Viewed (0) -
platforms/core-execution/persistent-cache/src/main/java/org/gradle/cache/FileLockManager.java
* released by calling {@link FileLock#close()}. This method blocks until the lock can be acquired. * <p> * Enable other processes to request access to the provided lock. Provided action runs when the lock access request is received * (it means that the lock is contended). * * @param target The file to be locked. * @param options The lock options.
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Tue Apr 16 15:49:51 UTC 2024 - 5.1K bytes - Viewed (0) -
hack/update-mocks.sh
# See the License for the specific language governing permissions and # limitations under the License. # This script generates mock files using mockgen. # Usage: `hack/update-mocks.sh`. set -o errexit set -o nounset set -o pipefail KUBE_ROOT=$(dirname "${BASH_SOURCE[0]}")/.. source "${KUBE_ROOT}/hack/lib/init.sh" kube::golang::setup_env echo 'installing mockgen'
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Mar 07 08:12:16 UTC 2024 - 4.4K bytes - Viewed (0) -
samples/bookinfo/src/details/Gemfile.lock
Brian Sonnenberg <******@****.***> 1716576125 -0700
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri May 24 18:42:05 UTC 2024 - 171 bytes - Viewed (0) -
platforms/core-execution/persistent-cache/src/main/java/org/gradle/cache/internal/btree/BTreePersistentIndexedCache.java
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Sep 22 09:08:47 UTC 2023 - 26.5K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/Monitor.java
} final ReentrantLock lock = this.lock; lock.lock(); boolean satisfied = false; try { return satisfied = guard.isSatisfied(); } finally { if (!satisfied) { lock.unlock(); } } } /** * Enters this monitor if the guard is satisfied. Blocks at most the given time acquiring the * lock, but does not wait for the guard to be satisfied.
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Mon Dec 04 18:22:01 UTC 2023 - 38.6K bytes - Viewed (0)