Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 21 - 30 of 54 for Interruption (0.28 seconds)

The search processing time has exceeded the limit. The displayed results may be partial.

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

        e.execute(() -> assertThat(Thread.currentThread().isInterrupted()).isFalse());
    
        // Run those tasks together.
        fakePool.runAll();
    
        // Check that the interruption of a SequentialExecutor's task is restored to the thread once
        // it is yielded. Clear the bit while checking so that the test doesn't hose JUnit or some other
        // test case.
        assertThat(Thread.interrupted()).isTrue();
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Mon Mar 16 22:45:21 GMT 2026
    - 10.5K bytes
    - Click Count (0)
  2. build-tools-internal/src/main/java/org/elasticsearch/gradle/internal/precommit/LicenseAnalyzer.java

                        + "NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF USE,\n"
                        + "DATA, OR PROFITS; OR BUSINESS INTERRUPTION\\) HOWEVER CAUSED AND ON ANY\n"
                        + "THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT\n"
                        + "\\(INCLUDING NEGLIGENCE OR OTHERWISE\\) ARISING IN ANY WAY OUT OF THE USE OF\n"
    Created: Wed Apr 08 16:19:15 GMT 2026
    - Last Modified: Tue Jul 27 00:12:58 GMT 2021
    - 12.8K bytes
    - Click Count (0)
  3. apache-maven/src/main/appended-resources/META-INF/NOTICE.vm

    COPYRIGHT OWNER OR CONTRIBUTORS BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE....
    Created: Sun Apr 05 03:35:12 GMT 2026
    - Last Modified: Sat Sep 10 19:27:25 GMT 2022
    - 5.5K bytes
    - Click Count (0)
  4. android/guava-tests/test/com/google/common/util/concurrent/AbstractFutureBenchmarks.java

          }
          executionList.execute();
          if (mayInterruptIfRunning) {
            interruptTask();
          }
          return true;
        }
    
        /**
         * Subclasses can override this method to implement interruption of the future's computation.
         * The method is invoked automatically by a successful call to {@link #cancel(boolean)
         * cancel(true)}.
         *
         * <p>The default implementation does nothing.
         *
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Sat Mar 07 02:20:33 GMT 2026
    - 13.8K bytes
    - Click Count (0)
  5. docs/changelogs/changelog_1x.md

    _2014-03-29_
    
     * Fix bug where the Content-Length header was not always dropped when
       following a redirect from a POST to a GET.
     * Implement basic support for `Thread.interrupt()`. OkHttp now checks
       for an interruption before doing a blocking call. If it is interrupted,
       it throws an `InterruptedIOException`.
    
    ## Version 1.5.2
    
    _2014-03-17_
    
     * Fix bug where deleting a file that was absent from the `HttpResponseCache`
    Created: Fri Apr 03 11:42:14 GMT 2026
    - Last Modified: Sun Feb 06 02:19:09 GMT 2022
    - 6.4K bytes
    - Click Count (0)
  6. android/guava/src/com/google/common/util/concurrent/Uninterruptibles.java

       * href="https://errorprone.info/bugpattern/WaitNotInLoop">the standard, required loop for waiting on a {@code
       * Condition}</a> but without the need to handle interruption.
       *
       * @return {@code false} if the waiting time detectably elapsed before return from the method
       * @since 33.4.0 (but since 28.0 in the JRE flavor)
       */
      @J2ktIncompatible
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Thu Jan 29 23:24:32 GMT 2026
    - 22.5K bytes
    - Click Count (0)
  7. okhttp-testing-support/src/main/kotlin/okhttp3/internal/concurrent/TaskFaker.kt

              currentTask = coordinatorTask
              taskRunner.notifyAll()
            }
          }
    
        // Let the coordinator process its interruption.
        runTasks()
      }
    
      /** Ask a single task to proceed. Used by the test thread only. */
      fun runNextTask() {
        taskRunner.assertLockNotHeld()
    
        taskRunner.withLock {
    Created: Fri Apr 03 11:42:14 GMT 2026
    - Last Modified: Wed May 28 23:28:25 GMT 2025
    - 11.9K bytes
    - Click Count (0)
  8. LICENSE

       ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES
       (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES;
       LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND
       ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT
       (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE OF THIS
    Created: Tue Apr 07 12:39:13 GMT 2026
    - Last Modified: Mon Nov 29 17:31:56 GMT 2021
    - 13.3K bytes
    - Click Count (0)
  9. guava-tests/test/com/google/common/util/concurrent/SequentialExecutorTest.java

        e.execute(() -> assertThat(Thread.currentThread().isInterrupted()).isFalse());
    
        // Run those tasks together.
        fakePool.runAll();
    
        // Check that the interruption of a SequentialExecutor's task is restored to the thread once
        // it is yielded. Clear the bit while checking so that the test doesn't hose JUnit or some other
        // test case.
        assertThat(Thread.interrupted()).isTrue();
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Mon Mar 16 22:45:21 GMT 2026
    - 10.5K bytes
    - Click Count (0)
  10. okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/http/RetryAndFollowUpInterceptor.kt

        requestSendStarted: Boolean,
      ): Boolean {
        // If there was a protocol problem, don't recover.
        if (e is ProtocolException) {
          return false
        }
    
        // If there was an interruption don't recover, but if there was a timeout connecting to a route
        // we should try the next route (if there is one).
        if (e is InterruptedIOException) {
          return e is SocketTimeoutException && !requestSendStarted
    Created: Fri Apr 03 11:42:14 GMT 2026
    - Last Modified: Tue Jan 27 09:00:39 GMT 2026
    - 12.5K bytes
    - Click Count (0)
Back to Top