- Sort Score
- Num 10 results
- Language All
Results 1061 - 1070 of 1,149 for lock (0.03 seconds)
-
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();
Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Mon Mar 16 22:45:21 GMT 2026 - 25.6K bytes - Click Count (0) -
src/main/java/jcifs/dcerpc/msrpc/srvsvc.java
Created: Sun Apr 05 00:10:12 GMT 2026 - Last Modified: Sat Aug 16 01:32:48 GMT 2025 - 27K bytes - Click Count (0) -
CONTRIBUTING.md
start by trying one of the smaller/easier issues here i.e. [issues with the "good first issue" label](https://github.com/tensorflow/tensorflow/labels/good%20first%20issue) and then take a look at the [issues with the "contributions welcome" label](https://github.com/tensorflow/tensorflow/labels/stat%3Acontributions%20welcome). These are issues that we believe are particularly well suited for outside
Created: Tue Apr 07 12:39:13 GMT 2026 - Last Modified: Sat Jan 11 04:47:59 GMT 2025 - 15.9K bytes - Click Count (0) -
android/guava/src/com/google/common/io/CharSource.java
* that provide readers that are: * * <ul> * <li><b>Finite:</b> Many operations, such as {@link #length()} and {@link #read()}, will either * block indefinitely or fail if the source creates an infinite reader. * <li><b>Non-destructive:</b> A <i>destructive</i> reader will consume or otherwise alter the
Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Mon Feb 23 19:19:10 GMT 2026 - 25.7K bytes - Click Count (0) -
src/test/java/org/codelibs/fess/filter/LoadControlFilterTest.java
for (String path : apiPaths) { resetMocks(); mockRequest.setRequestURI(path); testableFilter.doFilter(mockRequest, mockResponse, mockFilterChain); assertFalse("Expected block for: " + path, mockFilterChain.wasDoFilterCalled()); assertEquals(429, mockResponse.getStatus()); } } // ===================================================================================
Created: Tue Mar 31 13:07:34 GMT 2026 - Last Modified: Sat Mar 21 06:04:58 GMT 2026 - 33.6K bytes - Click Count (0) -
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"); } /**
Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Mon Mar 16 22:45:21 GMT 2026 - 26.7K bytes - Click Count (0) -
guava/src/com/google/common/base/Predicates.java
* future changes to it will alter the behavior of the predicate. * * <p>This method can technically accept any {@code Collection<?>}, but using a typed collection * helps prevent bugs. This approach doesn't block any potential users since it is always possible * to use {@code Predicates.<Object>in()}. * * <p>You may prefer to use a method reference (e.g., {@code target::contains}) instead of thisCreated: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Sun Mar 08 16:16:42 GMT 2026 - 26.6K bytes - Click Count (0) -
src/test/java/jcifs/dcerpc/msrpc/samrTest.java
@DisplayName("SAMR Protocol Test Suite") class samrTest { @Mock private NdrBuffer mockNdrBuffer; @Mock private NdrBuffer mockDeferredBuffer; @Mock private rpc.policy_handle mockPolicyHandle; @Mock private rpc.sid_t mockSidT; @Mock private rpc.unicode_string mockUnicodeString; @Mock private lsarpc.LsarSidArray mockLsarSidArray; @BeforeEachCreated: Sun Apr 05 00:10:12 GMT 2026 - Last Modified: Thu Aug 14 05:31:44 GMT 2025 - 33.7K bytes - Click Count (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)
Created: Tue Apr 07 11:13:11 GMT 2026 - Last Modified: Tue Jan 28 04:20:09 GMT 2025 - 19.4K bytes - Click Count (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
Created: Tue Apr 07 11:13:11 GMT 2026 - Last Modified: Thu May 23 01:00:11 GMT 2024 - 19.6K bytes - Click Count (0)