Search Options

Results per page
Sort
Preferred Languages
Advance

Results 81 - 90 of 365 for timeouts (0.12 sec)

  1. guava/src/com/google/common/util/concurrent/FluentFuture.java

       * TimeoutException} wrapped in an {@link ExecutionException}) if the specified timeout expires.
       * If the timeout expires, not only will the output future finish, but also the input future
       * ({@code this}) will be cancelled and interrupted.
       *
       * @param timeout when to time out the future
       * @param scheduledExecutor The executor service to enforce the timeout.
       * @since 28.0 (but only since 33.4.0 in the Android flavor)
       */
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Sat Oct 19 00:51:36 UTC 2024
    - 19.6K bytes
    - Viewed (0)
  2. guava/src/com/google/common/util/concurrent/TimeLimiter.java

       *     annotation type, rather than an interface
       * @since 28.0
       */
      default <T> T newProxy(T target, Class<T> interfaceType, Duration timeout) {
        return newProxy(target, interfaceType, toNanosSaturated(timeout), TimeUnit.NANOSECONDS);
      }
    
      /**
       * Invokes a specified Callable, timing out after the specified time limit. If the target method
       * call finishes before the limit is reached, the return value or a wrapped exception is
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri May 12 18:32:03 UTC 2023
    - 15.3K bytes
    - Viewed (0)
  3. internal/dsync/drwmutex_test.go

    	if !drwm1.GetRLock(ctx1, cancel1, id, source, Options{Timeout: time.Second}) {
    		panic("Failed to acquire read lock")
    	}
    	// fmt.Println("1st read lock acquired, waiting...")
    
    	drwm2 := NewDRWMutex(ds, "simplelock")
    	ctx2, cancel2 := context.WithCancel(context.Background())
    	if !drwm2.GetRLock(ctx2, cancel2, id, source, Options{Timeout: time.Second}) {
    		panic("Failed to acquire read lock")
    	}
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sat Dec 24 03:49:07 UTC 2022
    - 9.7K bytes
    - Viewed (0)
  4. src/main/java/org/codelibs/fess/auth/chain/CommandChain.java

            private final Process process;
    
            private final long timeout;
    
            private boolean finished = false;
    
            private boolean teminated = false;
    
            public MonitorThread(final Process process, final long timeout) {
                this.process = process;
                this.timeout = timeout;
            }
    
            @Override
            public void run() {
    Registered: Thu Oct 31 13:40:30 UTC 2024
    - Last Modified: Thu Feb 22 01:37:57 UTC 2024
    - 9.3K bytes
    - Viewed (0)
  5. samples/slack/src/main/java/okhttp3/slack/SlackClient.java

        this.session = session;
        this.notifyAll();
      }
    
      /** Waits for an OAuth session for this client to be set. */
      public synchronized void awaitAccessToken(Timeout timeout) throws InterruptedIOException {
        while (session == null) {
          timeout.waitUntilNotified(this);
        }
      }
    
      /** Starts a real time messaging session. */
      public void startRtm() throws IOException {
        String accessToken;
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Sat Jan 12 03:31:36 UTC 2019
    - 3.4K bytes
    - Viewed (0)
  6. src/main/java/jcifs/Configuration.java

         * 
         * Property <tt>jcifs.smb.client.soTimeout</tt> (int, default 35000)
         * 
         * @return socket timeout, in milliseconds
         */
        int getSoTimeout ();
    
    
        /**
         * 
         * Property <tt>jcifs.smb.client.connTimeout</tt> (int, default 35000)
         * 
         * @return timeout for establishing a socket connection, in milliseconds
         */
        int getConnTimeout ();
    
    
        /**
    Registered: Sun Nov 03 00:10:13 UTC 2024
    - Last Modified: Thu Jan 05 13:06:39 UTC 2023
    - 18K bytes
    - Viewed (0)
  7. android/guava-testlib/src/com/google/common/util/concurrent/testing/SameThreadScheduledExecutorService.java

      @Override
      public boolean isTerminated() {
        return delegate.isTerminated();
      }
    
      @Override
      public boolean awaitTermination(long timeout, TimeUnit unit) throws InterruptedException {
        Preconditions.checkNotNull(unit, "unit must not be null!");
        return delegate.awaitTermination(timeout, unit);
      }
    
      @Override
      public <T> ListenableFuture<T> submit(Callable<T> task) {
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Tue Jul 02 18:21:29 UTC 2024
    - 6.4K bytes
    - Viewed (0)
  8. guava-testlib/src/com/google/common/util/concurrent/testing/SameThreadScheduledExecutorService.java

      @Override
      public boolean isTerminated() {
        return delegate.isTerminated();
      }
    
      @Override
      public boolean awaitTermination(long timeout, TimeUnit unit) throws InterruptedException {
        Preconditions.checkNotNull(unit, "unit must not be null!");
        return delegate.awaitTermination(timeout, unit);
      }
    
      @Override
      public <T> ListenableFuture<T> submit(Callable<T> task) {
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Tue Jul 02 18:21:29 UTC 2024
    - 6.4K bytes
    - Viewed (0)
  9. internal/ioutil/ioutil_test.go

    package ioutil
    
    import (
    	"bytes"
    	"context"
    	"errors"
    	"io"
    	"os"
    	"strings"
    	"testing"
    	"time"
    )
    
    type sleepWriter struct {
    	timeout time.Duration
    }
    
    func (w *sleepWriter) Write(p []byte) (n int, err error) {
    	time.Sleep(w.timeout)
    	return len(p), nil
    }
    
    func (w *sleepWriter) Close() error {
    	return nil
    }
    
    func TestDeadlineWorker(t *testing.T) {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed May 22 23:07:14 UTC 2024
    - 5.5K bytes
    - Viewed (0)
  10. android/guava/src/com/google/common/util/concurrent/ServiceManager.java

      }
    
      /**
       * Waits for the all the services to reach a terminal state for no more than the given time. After
       * this method returns all services will either be {@linkplain Service.State#TERMINATED
       * terminated} or {@linkplain Service.State#FAILED failed}.
       *
       * @param timeout the maximum time to wait
       * @param unit the time unit of the timeout argument
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Sat Oct 19 00:51:36 UTC 2024
    - 33.5K bytes
    - Viewed (0)
Back to top