Search Options

Results per page
Sort
Preferred Languages
Advance

Results 91 - 100 of 1,790 for dong (2.06 sec)

  1. 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)
  2. 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)
  3. 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)
  4. 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)
  5. 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)
  6. 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)
  7. 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)
  8. 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)
  9. 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 escaped
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Thu Feb 13 15:45:16 UTC 2025
    - 13.2K bytes
    - Viewed (0)
  10. 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)
Back to top