- Sort Score
- Num 10 results
- Language All
Results 1 - 10 of 191 for wlock (0.02 seconds)
-
internal/lru/lru.go
c.mu.Lock() bucketIdx := c.nextCleanupBucket timeToExpire := time.Until(c.buckets[bucketIdx].newestEntry) // wait for newest entry to expire before cleanup without holding lock if timeToExpire > 0 { c.mu.Unlock() time.Sleep(timeToExpire) c.mu.Lock() } for _, ent := range c.buckets[bucketIdx].entries { c.removeElement(ent) } c.nextCleanupBucket = (c.nextCleanupBucket + 1) % numBuckets
Created: Sun Apr 05 09:35:12 GMT 2026 - Last Modified: Sat Mar 21 11:35:55 GMT 2026 - 12.6K bytes - Click Count (0) -
guava-tests/test/com/google/common/util/concurrent/TestThread.java
* test with reference to the same "lock-like object", and then their interactions with that object * are choreographed via the various methods on this class. * * <p>A "lock-like object" is really any object that may be used for concurrency control. If the * {@link #callAndAssertBlocks} method is ever called in a test, the lock-like object must have a
Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Fri Mar 13 13:01:07 GMT 2026 - 11.5K bytes - Click Count (0) -
android/guava/src/com/google/common/util/concurrent/Monitor.java
} 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.Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Wed Jan 28 22:39:02 GMT 2026 - 43.5K bytes - Click Count (0) -
android/guava-tests/test/com/google/common/util/concurrent/TestThread.java
* test with reference to the same "lock-like object", and then their interactions with that object * are choreographed via the various methods on this class. * * <p>A "lock-like object" is really any object that may be used for concurrency control. If the * {@link #callAndAssertBlocks} method is ever called in a test, the lock-like object must have a
Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Fri Mar 13 13:01:07 GMT 2026 - 11.5K bytes - Click Count (0) -
src/main/webapp/WEB-INF/orig/view/login/newpassword.jsp
<div class="input-group-append"> <span class="input-group-text"> <i class="fa fa-lock fa-fw" aria-hidden="true"></i> </span> </div> </div> <div class="text-center"> <button type="submit" name="changePassword" class="btn btn-primary btn-block" value="<la:message key="labels.login.update"/>"> <i class="fa fa-pencil-alt" aria-hidden="true"></i>
Created: Tue Mar 31 13:07:34 GMT 2026 - Last Modified: Mon Feb 23 08:03:44 GMT 2026 - 3.1K bytes - Click Count (0) -
android/guava/src/com/google/common/util/concurrent/ExecutionList.java
private final Object lock = new Object(); /** * The runnable, executor pairs to execute. This acts as a stack threaded through the {@link * RunnableExecutorPair#next} field. */ @GuardedBy("lock") private @Nullable RunnableExecutorPair runnables; @GuardedBy("lock") private boolean executed; /** Creates a new, empty {@link ExecutionList}. */
Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Tue Feb 10 11:51:21 GMT 2026 - 6.9K bytes - Click Count (0) -
src/main/webapp/WEB-INF/orig/view/login/index.jsp
<div class="input-group-append"> <span class="input-group-text"> <i class="fa fa-lock fa-fw" aria-hidden="true"></i> </span> </div> </div> <div class="text-center"> <button type="submit" name="login" class="btn btn-primary btn-block" value="<la:message key="labels.login"/>"> <i class="fa fa-sign-in" aria-hidden="true"></i>
Created: Tue Mar 31 13:07:34 GMT 2026 - Last Modified: Mon Feb 23 08:03:44 GMT 2026 - 3K bytes - Click Count (0) -
okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/http2/Http2Connection.kt
* window sufficient to send [byteCount], the caller will block. For example, a user of * `HttpURLConnection` who flushes more bytes to the output stream than the connection's write * window will block. * * Zero [byteCount] writes are not subject to flow control and will not block. The only use case * for zero [byteCount] is closing a flushed output stream. */
Created: Fri Apr 03 11:42:14 GMT 2026 - Last Modified: Tue Jan 27 09:00:39 GMT 2026 - 31.9K bytes - Click Count (0) -
guava-tests/test/com/google/common/util/concurrent/AbstractFutureBenchmarks.java
: t; releaseShared(finalState); } else if (getState() == COMPLETING) { // If some other thread is currently completing the future, block until // they are done so we can guarantee completion. acquireShared(-1); } return doCompletion; } }Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Sat Mar 07 02:20:33 GMT 2026 - 13.8K bytes - Click Count (0) -
android/guava/src/com/google/common/util/concurrent/Uninterruptibles.java
} /** * Invokes {@code lock.}{@link Lock#tryLock(long, TimeUnit) tryLock(timeout, unit)} * uninterruptibly. * * @since 30.0 */ @J2ktIncompatible @GwtIncompatible // concurrency @SuppressWarnings("GoodTime") // should accept a java.time.Duration public static boolean tryLockUninterruptibly(Lock lock, long timeout, TimeUnit unit) {Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Thu Jan 29 23:24:32 GMT 2026 - 22.5K bytes - Click Count (0)