- Sort Score
- Result 10 results
- Languages All
Results 91 - 100 of 1,790 for dong (0.65 sec)
-
internal/dsync/dsync_test.go
// fmt.Println("Unlocking dm1") dm1st.Unlock(t.Context()) }() expect += 2 * testDrwMutexAcquireTimeout var wg sync.WaitGroup wg.Add(2) go func() { defer wg.Done() dm2nd.Lock(id, source) // Release lock after 10 seconds go func() { time.Sleep(2 * testDrwMutexAcquireTimeout) // fmt.Println("Unlocking dm2") dm2nd.Unlock(t.Context()) }()
Registered: Sun Dec 28 19:28:13 UTC 2025 - Last Modified: Fri Aug 29 02:39:48 UTC 2025 - 10.8K bytes - Viewed (0) -
build-logic/cleanup/src/test/groovy/gradlebuild/cleanup/services/LeakingProcessKillPatternTest.groovy
'"C:\\Program Files\\Java\\jdk1.7/bin/java.exe" -Dorg.gradle.daemon.idletimeout=120000 -Dorg.gradle.daemon.registry.base=C:\\some\\agent\\workspace\\build\\daemon -Dorg.gradle.native.dir=C:\\some\\agent\\workspace\\intTestHomeDir\\worker-1\\native -Dorg.gradle.deprecation.trace=true -Djava.io.tmpdir=C:\\some\\agent\\workspace\\subprojects\\osgi\\build\\tmp -Dfile.encoding=windows-1252 -Dorg.gradle.classloaderscope.strict=true -ea -ea "-Dorg.gradle.appname=gradle" -classpath "C:\\some\\agent\\...
Registered: Wed Dec 31 11:36:14 UTC 2025 - Last Modified: Fri Jul 12 03:42:46 UTC 2024 - 14.8K bytes - Viewed (0) -
guava/src/com/google/common/collect/CompactLinkedHashMap.java
} private void setSuccessor(int entry, int succ) { long succMask = ~0L >>> 32; setLink(entry, (link(entry) & ~succMask) | ((succ + 1) & succMask)); } private void setPredecessor(int entry, int pred) { long predMask = ~0L << 32; setLink(entry, (link(entry) & ~predMask) | ((long) (pred + 1) << 32)); } private void setSucceeds(int pred, int succ) {
Registered: Fri Dec 26 12:43:10 UTC 2025 - Last Modified: Sat Aug 09 01:14:59 UTC 2025 - 10.2K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/util/concurrent/TestPlatform.java
} /** * Retrieves the result of a {@code Future} known to be done but uses the {@code get(long, * TimeUnit)} overload in order to test that method. */ static <V extends @Nullable Object> V getDoneFromTimeoutOverload(Future<V> future) throws ExecutionException { checkState(future.isDone(), "Future was expected to be done: %s", future); try { return getUninterruptibly(future, 0, SECONDS);Registered: Fri Dec 26 12:43:10 UTC 2025 - Last Modified: Thu Aug 07 16:05:33 UTC 2025 - 2.7K bytes - Viewed (0) -
cmd/metacache-stream.go
// readAll will return all remaining objects on the dst channel and close it when done. // The context allows the operation to be canceled. func (r *metacacheReader) readAll(ctx context.Context, dst chan<- metaCacheEntry) error { r.checkInit() if r.err != nil { return r.err } defer xioutil.SafeClose(dst) if r.current.name != "" { select { case <-ctx.Done(): r.err = ctx.Err() return ctx.Err()
Registered: Sun Dec 28 19:28:13 UTC 2025 - Last Modified: Wed May 07 15:37:12 UTC 2025 - 19.5K bytes - Viewed (0) -
compat/maven-compat/src/main/java/org/apache/maven/project/artifact/MavenMetadataSource.java
message); } } else { done = true; } } else { done = true; } } } while (!done); ProjectRelocation rel = new ProjectRelocation(); rel.project = project; rel.pomArtifact = pomArtifact;Registered: Sun Dec 28 03:35:09 UTC 2025 - Last Modified: Thu Sep 25 12:03:50 UTC 2025 - 30.4K bytes - Viewed (0) -
fess-crawler/src/main/java/org/codelibs/fess/crawler/Crawler.java
* Stops the crawling process. * Sets the crawler status to DONE and interrupts all crawler threads. */ public void stop() { if (logger.isInfoEnabled()) { logger.info("Stopping crawler: sessionId={}, status={}", crawlerContext.sessionId, crawlerContext.getStatus()); } crawlerContext.setStatus(CrawlerStatus.DONE); try { if (crawlerThreadGroup != null) {Registered: Sat Dec 20 11:21:39 UTC 2025 - Last Modified: Mon Nov 24 03:59:47 UTC 2025 - 17K bytes - Viewed (0) -
docs/en/docs/advanced/custom-response.md
3. This `yield from` tells the function to iterate over that thing named `file_like`. And then, for each part iterated, yield that part as coming from this generator function (`iterfile`). So, it is a generator function that transfers the "generating" work to something else internally.
Registered: Sun Dec 28 07:19:09 UTC 2025 - Last Modified: Wed Dec 17 20:41:43 UTC 2025 - 12.4K bytes - Viewed (0) -
android/guava/src/com/google/common/escape/UnicodeEscaper.java
* * <p><b>Note:</b> When implementing an escaper it is a good idea to override this method for * efficiency by inlining the implementation of {@link #nextEscapeIndex(CharSequence, int, int)} * directly. Doing this for {@link com.google.common.net.PercentEscaper} more than doubled the * performance for unescaped strings (as measured by {@code CharEscapersBenchmark}). * * @param string the literal string to be escapedRegistered: Fri Dec 26 12:43:10 UTC 2025 - Last Modified: Thu Feb 13 15:45:16 UTC 2025 - 13.2K bytes - Viewed (0) -
guava-tests/test/com/google/common/util/concurrent/MoreExecutorsTest.java
/* * Portions of this file are modified versions of * http://gee.cs.oswego.edu/cgi-bin/viewcvs.cgi/jsr166/src/test/tck/AbstractExecutorServiceTest.java?revision=1.30 * which contained the following notice: * * Written by Doug Lea with assistance from members of JCP JSR-166 * Expert Group and released to the public domain, as explained at * http://creativecommons.org/publicdomain/zero/1.0/ * Other contributors include Andrew Wright, Jeffrey Hayes,
Registered: Fri Dec 26 12:43:10 UTC 2025 - Last Modified: Fri Dec 12 00:25:21 UTC 2025 - 26.5K bytes - Viewed (0)