Search Options

Results per page
Sort
Preferred Languages
Advance

Results 61 - 70 of 74 for Interrupter (0.09 sec)

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

     * in a few ways:
     *
     * <ul>
     *   <li>Each task may be associated with a different executor.
     *   <li>Tasks may be of type {@code AsyncCallable}.
     *   <li>Running tasks <i>cannot</i> be interrupted. (Note that {@code newSequentialExecutor} does
     *       not return {@code Future} objects, so it doesn't support interruption directly, either.
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Thu Feb 01 21:46:34 UTC 2024
    - 22.1K bytes
    - Viewed (0)
  2. guava-tests/test/com/google/common/io/testdata/alice_in_wonderland.txt

      `Exactly so,' said the Hatter:  `as the things get used up.'
    
      `But what happens when you come to the beginning again?' Alice
    ventured to ask.
    
      `Suppose we change the subject,' the March Hare interrupted,
    yawning.  `I'm getting tired of this.  I vote the young lady
    tells us a story.'
    
      `I'm afraid I don't know one,' said Alice, rather alarmed at
    the proposal.
    
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Mon Oct 29 21:35:03 UTC 2012
    - 145.2K bytes
    - Viewed (0)
  3. compat/maven-compat/src/main/java/org/apache/maven/artifact/resolver/DefaultArtifactResolver.java

                try {
                    latch.await();
                } catch (InterruptedException e) {
                    result.addErrorArtifactException(
                            new ArtifactResolutionException("Resolution interrupted", rootArtifact, e));
                }
            }
    
            // We want to send the root artifact back in the result but we need to do this after the other dependencies
            // have been resolved.
    Registered: Sun Nov 03 03:35:11 UTC 2024
    - Last Modified: Fri Oct 25 12:31:46 UTC 2024
    - 24.8K bytes
    - Viewed (0)
  4. cmd/endpoint.go

    		// This is needed as the remote hosts are sometime
    		// not available immediately.
    		select {
    		case <-globalOSSignalCh:
    			return fmt.Errorf("The endpoint resolution got interrupted")
    		default:
    			for i, resolved := range resolvedList {
    				if resolved {
    					// Continue if host is already resolved.
    					continue
    				}
    
    				if endpoints[i].Host == "" {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Jun 21 22:22:24 UTC 2024
    - 34.2K bytes
    - Viewed (0)
  5. android/guava/src/com/google/common/util/concurrent/Futures.java

       * Returns a future that delegates to another but will finish early (via a {@link
       * TimeoutException} wrapped in an {@link ExecutionException}) if the specified duration expires.
       *
       * <p>The delegate future is interrupted and cancelled if it times out.
       *
       * @param delegate The future to delegate to.
       * @param time when to time out the future
       * @param scheduledExecutor The executor service to enforce the timeout.
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri Oct 25 13:13:32 UTC 2024
    - 64.7K bytes
    - Viewed (0)
  6. okhttp/src/main/kotlin/okhttp3/internal/http2/Http2Connection.kt

                }
                condition.await() // Wait until we receive a WINDOW_UPDATE.
              }
            } catch (e: InterruptedException) {
              Thread.currentThread().interrupt() // Retain interrupted status.
              throw InterruptedIOException()
            }
    
            toWrite = minOf(byteCount, writeBytesMaximum - writeBytesTotal).toInt()
            toWrite = minOf(toWrite, writer.maxDataLength())
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Sat Apr 20 17:03:43 UTC 2024
    - 32.6K bytes
    - Viewed (0)
  7. android/guava/src/com/google/common/util/concurrent/ExecutionSequencer.java

     * in a few ways:
     *
     * <ul>
     *   <li>Each task may be associated with a different executor.
     *   <li>Tasks may be of type {@code AsyncCallable}.
     *   <li>Running tasks <i>cannot</i> be interrupted. (Note that {@code newSequentialExecutor} does
     *       not return {@code Future} objects, so it doesn't support interruption directly, either.
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Thu Feb 01 21:46:34 UTC 2024
    - 22.1K bytes
    - Viewed (0)
  8. docs/changelogs/changelog_3x.md

     *  Fix: Reverse suppression of connect exceptions. When both a call and its retry fail, we now
        throw the initial exception which is most likely to be actionable.
     *  Fix: Retain interrupted state when throwing `InterruptedIOException`. A single interrupt should
        now be sufficient to break out an in-flight OkHttp call.
     *  Fix: Don't drop a call to `EventListener.callEnd()` when the response body is consumed inside an
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Sun Feb 06 14:55:54 UTC 2022
    - 50.8K bytes
    - Viewed (0)
  9. src/main/java/jcifs/smb/SmbTransportImpl.java

                            }
                            break;
                        }
                        catch ( InterruptedException e ) {
                            InterruptedIOException ie = new InterruptedIOException("Interrupted while acquiring credits");
                            ie.initCause(e);
                            throw ie;
                        }
                    }
                    else {
    Registered: Sun Nov 03 00:10:13 UTC 2024
    - Last Modified: Wed Jan 18 23:47:00 UTC 2023
    - 67K bytes
    - Viewed (0)
  10. guava/src/com/google/common/util/concurrent/Futures.java

       * Returns a future that delegates to another but will finish early (via a {@link
       * TimeoutException} wrapped in an {@link ExecutionException}) if the specified duration expires.
       *
       * <p>The delegate future is interrupted and cancelled if it times out.
       *
       * @param delegate The future to delegate to.
       * @param time when to time out the future
       * @param scheduledExecutor The executor service to enforce the timeout.
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri Oct 25 13:13:32 UTC 2024
    - 64.4K bytes
    - Viewed (0)
Back to top