- Sort Score
- Result 10 results
- Languages All
Results 291 - 300 of 333 for Unlock (0.09 sec)
-
android/guava/src/com/google/common/util/concurrent/Uninterruptibles.java
@IgnoreJRERequirement // Users will use this only if they're already using Duration. public static boolean tryLockUninterruptibly(Lock lock, Duration timeout) { return tryLockUninterruptibly(lock, toNanosSaturated(timeout), TimeUnit.NANOSECONDS); } /** * Invokes {@code lock.}{@link Lock#tryLock(long, TimeUnit) tryLock(timeout, unit)} * uninterruptibly. * * @since 30.0 */ @J2ktIncompatible
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Sat Oct 19 00:51:36 UTC 2024 - 20.1K bytes - Viewed (0) -
cmd/xl-storage-format_test.go
} if unMarshalXLMeta.Erasure.BlockSize != jsoniterXLMeta.Erasure.BlockSize { t.Errorf("Expected the erasure block size to be %v, but got %v.", unMarshalXLMeta.Erasure.BlockSize, jsoniterXLMeta.Erasure.BlockSize) } if unMarshalXLMeta.Erasure.Index != jsoniterXLMeta.Erasure.Index {
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Thu Feb 22 06:26:06 UTC 2024 - 17.6K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/util/concurrent/GeneratedMonitorTest.java
return method.getName().startsWith("enter") || method.getName().startsWith("tryEnter"); } /** Identifies just tryEnterXxx methods (a subset of {@link #isAnyEnter}), which never block. */ private static boolean isTryEnter(Method method) { return method.getName().startsWith("tryEnter"); } /**
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Sat Oct 19 00:51:36 UTC 2024 - 27.1K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/util/concurrent/ServiceManagerTest.java
manager.addListener( new ServiceManager.Listener() { @Override public void failure(Service service) { failEnter.countDown(); // block until after the service manager is shutdown Uninterruptibles.awaitUninterruptibly(failLeave); } }, directExecutor()); manager.startAsync(); afterStarted.countDown();
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Sat Oct 19 00:51:36 UTC 2024 - 25.5K bytes - Viewed (0) -
guava-tests/test/com/google/common/hash/HashTestUtils.java
} } } /** * Test for 2-bit characteristics. A characteristic is a delta in the input which is repeated in * the output. For example, if f() is a block cipher and c is a characteristic, then f(x^c) = * f(x)^c with greater than expected probability. The test for funneling is merely a test for * 1-bit characteristics. *
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Tue Jul 23 14:22:54 UTC 2024 - 25.5K bytes - Viewed (0) -
api/go1.3.txt
pkg syscall (darwin-386), func FcntlFlock(uintptr, int, *Flock_t) error pkg syscall (darwin-386), func Mlock([]uint8) error pkg syscall (darwin-386), func Mlockall(int) error pkg syscall (darwin-386), func Mprotect([]uint8, int) error pkg syscall (darwin-386), func Munlock([]uint8) error pkg syscall (darwin-386), func Munlockall() error
Registered: Tue Nov 05 11:13:11 UTC 2024 - Last Modified: Mon Jun 02 02:45:00 UTC 2014 - 117K bytes - Viewed (0) -
src/archive/zip/writer.go
// 32 bit size fields (and offset later) to signal that the // zip64 extra header should be used. b.uint32(uint32max) // compressed size b.uint32(uint32max) // uncompressed size // append a zip64 extra block to Extra var buf [28]byte // 2x uint16 + 3x uint64 eb := writeBuf(buf[:]) eb.uint16(zip64ExtraID) eb.uint16(24) // size = 3x uint64 eb.uint64(h.UncompressedSize64) eb.uint64(h.CompressedSize64)
Registered: Tue Nov 05 11:13:11 UTC 2024 - Last Modified: Mon Sep 23 14:32:33 UTC 2024 - 19.4K bytes - Viewed (0) -
src/archive/zip/zip_test.go
if _, err := zip.ReadAt(d, zip.Size()-int64(len(d))); err != nil { t.Fatalf("ReadAt: %v", err) } sigOff := findSignatureInBlock(d) if sigOff == -1 { t.Errorf("failed to find signature in block") return false } dirOff, err := findDirectory64End(zip, zip.Size()-int64(len(d))+int64(sigOff)) if err != nil { t.Fatalf("findDirectory64End: %v", err) } if dirOff == -1 { return false
Registered: Tue Nov 05 11:13:11 UTC 2024 - Last Modified: Thu May 23 01:00:11 UTC 2024 - 19.6K bytes - Viewed (0) -
tensorflow/c/eager/c_api_experimental.cc
"Coordination service is not enabled."); return; } absl::Duration timeout; if (timeout_in_ms > 0) { timeout = absl::Milliseconds(timeout_in_ms); } else { // Block until the key-value is set or the worker shuts down. timeout = absl::InfiniteDuration(); } auto status_or_value = coord_agent->GetKeyValue(key, timeout); status->status = status_or_value.status();
Registered: Tue Nov 05 12:39:12 UTC 2024 - Last Modified: Sat Oct 12 05:11:17 UTC 2024 - 35.9K bytes - Viewed (0) -
src/main/webapp/js/jquery-3.7.1.min.js
ll==(l=v&&v.display)&&(l=_.get(e,"display")),"none"===(c=ce.css(e,"display"))&&(l?c=l:(re([e],!0),l=e.style.display||l,c=ce.css(e,"display"),re([e]))),("inline"===c||"inline-block"===c&&null!=l)&&"none"===ce.css(e,"float")&&(u||(p.done(function(){h.display=l}),null==l&&(c=h.display,l="none"===c?"":c)),h.display="inline-block")),n.overflow&&(h.overflow="hidden",p.always(function(){h.overflow=n.overflow[0],h.overflowX=n.overflow[1],h.overflowY=n.overflow[2]})),u=!1,d)u||(v?"hidden"in v&&(g=v.hidde...
Registered: Thu Oct 31 13:40:30 UTC 2024 - Last Modified: Sat Oct 26 01:07:52 UTC 2024 - 85.5K bytes - Viewed (0)