Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 45 for waits (0.18 sec)

  1. android/guava-tests/test/com/google/common/util/concurrent/JSR166TestCase.java

          threadUnexpectedException(t);
        }
      }
    
      //     /**
      //      * Spin-waits up to LONG_DELAY_MS until flag becomes true.
      //      */
      //     public void await(AtomicBoolean flag) {
      //         await(flag, LONG_DELAY_MS);
      //     }
    
      //     /**
      //      * Spin-waits up to the specified timeout until flag becomes true.
      //      */
    Registered: Wed Jun 12 16:38:11 UTC 2024
    - Last Modified: Mon Jun 10 19:21:11 UTC 2024
    - 37.7K bytes
    - Viewed (0)
  2. src/os/exec/exec.go

    //
    // If any of c.Stdin, c.Stdout or c.Stderr are not an [*os.File], Wait also waits
    // for the respective I/O loop copying to or from the process to complete.
    //
    // Wait releases any resources associated with the [Cmd].
    func (c *Cmd) Wait() error {
    	if c.Process == nil {
    		return errors.New("exec: not started")
    	}
    	if c.ProcessState != nil {
    		return errors.New("exec: Wait was already called")
    	}
    
    	state, err := c.Process.Wait()
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Fri Jun 07 20:13:53 UTC 2024
    - 41.4K bytes
    - Viewed (0)
  3. cmd/batch-expire.go

    	if len(toDel) > 0 {
    		select {
    		case <-ctx.Done():
    		case expireCh <- toDel:
    		}
    	}
    	xioutil.SafeClose(expireCh)
    
    	<-expireDoneCh // waits for the expire goroutine to complete
    	wk.Wait()      // waits for all expire workers to retire
    
    	ri.Complete = !failed && ri.ObjectsFailed == 0
    	ri.Failed = failed || ri.ObjectsFailed > 0
    	globalBatchJobsMetrics.save(job.ID, ri)
    
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Tue Jun 11 13:50:53 UTC 2024
    - 21.1K bytes
    - Viewed (0)
  4. android/guava-tests/test/com/google/common/util/concurrent/TestThread.java

      /**
       * Asserts that a prior call that had caused this thread to block or wait has since returned
       * normally.
       */
      public void assertPriorCallReturns(@Nullable String methodName) throws Exception {
        assertEquals(null, getResponse(methodName).getResult());
      }
    
      /**
       * Asserts that a prior call that had caused this thread to block or wait has since returned the
       * expected boolean value.
       */
    Registered: Wed Jun 12 16:38:11 UTC 2024
    - Last Modified: Tue Jun 11 16:13:05 UTC 2024
    - 10.8K bytes
    - Viewed (0)
  5. guava-tests/test/com/google/common/util/concurrent/TestThread.java

      /**
       * Asserts that a prior call that had caused this thread to block or wait has since returned
       * normally.
       */
      public void assertPriorCallReturns(@Nullable String methodName) throws Exception {
        assertEquals(null, getResponse(methodName).getResult());
      }
    
      /**
       * Asserts that a prior call that had caused this thread to block or wait has since returned the
       * expected boolean value.
       */
    Registered: Wed Jun 12 16:38:11 UTC 2024
    - Last Modified: Tue Jun 11 16:13:05 UTC 2024
    - 10.8K bytes
    - Viewed (0)
  6. src/os/exec.go

    	return p.kill()
    }
    
    // Wait waits for the [Process] to exit, and then returns a
    // ProcessState describing its status and an error, if any.
    // Wait releases any resources associated with the Process.
    // On most operating systems, the Process must be a child
    // of the current process or an error will be returned.
    func (p *Process) Wait() (*ProcessState, error) {
    	return p.wait()
    }
    
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Mon Jun 10 22:06:47 UTC 2024
    - 12.8K bytes
    - Viewed (0)
  7. src/crypto/tls/tls.go

    	}
    	c.handshakeFn = c.clientHandshake
    	return c
    }
    
    // A listener implements a network listener (net.Listener) for TLS connections.
    type listener struct {
    	net.Listener
    	config *Config
    }
    
    // Accept waits for and returns the next incoming TLS connection.
    // The returned connection is of type *Conn.
    func (l *listener) Accept() (net.Conn, error) {
    	c, err := l.Listener.Accept()
    	if err != nil {
    		return nil, err
    	}
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Fri Jun 07 17:57:01 UTC 2024
    - 12.2K bytes
    - Viewed (0)
  8. platforms/documentation/docs/src/docs/userguide/optimizing-performance/gradle_daemon.adoc

    The Daemon can reduce build times by 15-75% when you build the same project repeatedly.
    
    TIP: To understand the Daemon's impact on your builds, you can profile your build with `--profile`.
    
    In between builds, the Daemon waits idly for the next build.
    As a result, your machine only loads Gradle into memory once for multiple builds instead of once per build.
    This is a significant performance optimization.
    
    === Runtime Code Optimizations
    
    Registered: Wed Jun 12 18:38:38 UTC 2024
    - Last Modified: Fri Jun 07 12:43:14 UTC 2024
    - 13.1K bytes
    - Viewed (0)
  9. staging/src/k8s.io/apiserver/pkg/storage/cacher/watch_cache.go

    }
    
    // List returns list of pointers to <storeElement> objects.
    func (w *watchCache) List() []interface{} {
    	return w.store.List()
    }
    
    // waitUntilFreshAndBlock waits until cache is at least as fresh as given <resourceVersion>.
    // NOTE: This function acquired lock and doesn't release it.
    // You HAVE TO explicitly call w.RUnlock() after this function.
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Jun 11 10:20:57 UTC 2024
    - 26.2K bytes
    - Viewed (0)
  10. cmd/bucket-lifecycle.go

    // to tasks channel being backlogged.
    func (t *transitionState) MissedImmediateTasks() int64 {
    	return t.missedImmediateTasks.Load()
    }
    
    // worker waits for transition tasks
    func (t *transitionState) worker(objectAPI ObjectLayer) {
    	for {
    		select {
    		case <-t.killCh:
    			return
    		case <-t.ctx.Done():
    			return
    		case task, ok := <-t.transitionCh:
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Mon Jun 10 15:31:51 UTC 2024
    - 33.3K bytes
    - Viewed (0)
Back to top