Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 6 of 6 for interrupted (0.08 sec)

  1. android/guava-tests/test/com/google/common/cache/CacheLoadingTest.java

        assertEquals(0, stats.hitCount());
    
        // Sanity check:
        assertFalse(Thread.interrupted());
    
        Exception expected = assertThrows(ExecutionException.class, () -> cache.get(new Object()));
        assertThat(expected).hasCauseThat().isSameInstanceAs(e);
        assertTrue(Thread.interrupted());
        stats = cache.stats();
        assertEquals(1, stats.missCount());
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri Oct 18 19:07:49 UTC 2024
    - 86.3K bytes
    - Viewed (0)
  2. android/guava/src/com/google/common/util/concurrent/Futures.java

        Future<?> scheduled = executorService.schedule(task, delay, timeUnit);
        /*
         * Even when the user interrupts the task, we pass `false` to `cancel` so that we don't
         * interrupt a second time after the interruption performed by TrustedListenableFutureTask.
         */
        task.addListener(() -> scheduled.cancel(false), directExecutor());
        return task;
      }
    
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri Oct 25 13:13:32 UTC 2024
    - 64.7K bytes
    - Viewed (0)
  3. guava/src/com/google/common/util/concurrent/Futures.java

        Future<?> scheduled = executorService.schedule(task, delay, timeUnit);
        /*
         * Even when the user interrupts the task, we pass `false` to `cancel` so that we don't
         * interrupt a second time after the interruption performed by TrustedListenableFutureTask.
         */
        task.addListener(() -> scheduled.cancel(false), directExecutor());
        return task;
      }
    
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri Oct 25 13:13:32 UTC 2024
    - 64.4K bytes
    - Viewed (0)
  4. 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
        interceptor.
    
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Sun Feb 06 14:55:54 UTC 2022
    - 50.8K bytes
    - Viewed (0)
  5. 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)
  6. src/main/java/jcifs/smb/SmbFile.java

                }
                finally {
                    w.write(null, -1, null);
                    w.interrupt();
                    try {
                        w.join();
                    }
                    catch ( InterruptedException e ) {
                        log.warn("Interrupted while joining copy thread", e);
                    }
                }
            }
            catch ( CIFSException e ) {
    Registered: Sun Nov 03 00:10:13 UTC 2024
    - Last Modified: Thu May 23 01:50:13 UTC 2024
    - 82.3K bytes
    - Viewed (0)
Back to top