Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 28 for isCanceled (0.14 sec)

  1. src/main/java/org/codelibs/fess/job/GenerateThumbnailJob.java

                logger.warn("Failed to generate thumbnails.", e);
                resultBuf.append(e.getMessage()).append("\n");
            } finally {
                if (timeoutTask != null && !timeoutTask.isCanceled()) {
                    timeoutTask.cancel();
                }
            }
    
            return resultBuf.toString();
    
        }
    
        protected void executeThumbnailGenerator() {
    Registered: Thu Oct 31 13:40:30 UTC 2024
    - Last Modified: Fri Oct 11 21:20:39 UTC 2024
    - 10.6K bytes
    - Viewed (0)
  2. fess-crawler/src/main/java/org/codelibs/fess/crawler/client/ftp/FtpClient.java

                return getResponseData(uri, includeContent);
            } finally {
                if (accessTimeoutTarget != null) {
                    accessTimeoutTarget.stop();
                    if (!accessTimeoutTask.isCanceled()) {
                        accessTimeoutTask.cancel();
                    }
                }
            }
        }
    
        protected ResponseData getResponseData(final String uri, final boolean includeContent) {
    Registered: Sun Nov 10 03:50:12 UTC 2024
    - Last Modified: Sat Oct 12 01:41:37 UTC 2024
    - 25.7K bytes
    - Viewed (0)
  3. android/guava-tests/test/com/google/common/util/concurrent/SettableFutureTest.java

        // Check that the future has been set properly.
        assertFalse(future.isDone());
        assertFalse(future.isCancelled());
        assertThrows(TimeoutException.class, () -> future.get(0, MILLISECONDS));
        nested.set("foo");
        assertTrue(future.isDone());
        assertFalse(future.isCancelled());
        assertEquals("foo", future.get());
      }
    
      private static class Foo {}
    
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri Oct 18 22:10:29 UTC 2024
    - 7.3K bytes
    - Viewed (0)
  4. guava-tests/test/com/google/common/util/concurrent/SettableFutureTest.java

        // Check that the future has been set properly.
        assertFalse(future.isDone());
        assertFalse(future.isCancelled());
        assertThrows(TimeoutException.class, () -> future.get(0, MILLISECONDS));
        nested.set("foo");
        assertTrue(future.isDone());
        assertFalse(future.isCancelled());
        assertEquals("foo", future.get());
      }
    
      private static class Foo {}
    
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri Oct 18 22:10:29 UTC 2024
    - 7.3K bytes
    - Viewed (0)
  5. guava-tests/test/com/google/common/util/concurrent/ListenableFutureTester.java

        assertEquals(expectedValue, future.get());
      }
    
      public void testCancelledFuture() throws InterruptedException, ExecutionException {
        assertTrue(future.isDone());
        assertTrue(future.isCancelled());
    
        assertTrue(latch.await(5, SECONDS));
        assertTrue(future.isDone());
        assertTrue(future.isCancelled());
    
        assertThrows(CancellationException.class, () -> future.get());
      }
    
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri Oct 18 22:10:29 UTC 2024
    - 3.3K bytes
    - Viewed (0)
  6. guava-tests/test/com/google/common/util/concurrent/ListenableFutureTaskTest.java

        assertFalse(task.isCancelled());
    
        // Start the task to put it in the RUNNING state.  Have to use a separate
        // thread because the task will block on the task latch after unblocking
        // the run latch.
        exec.execute(task);
        runLatch.await();
        assertEquals(1, listenerLatch.getCount());
        assertFalse(task.isDone());
        assertFalse(task.isCancelled());
    
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri Oct 18 22:10:29 UTC 2024
    - 4.7K bytes
    - Viewed (0)
  7. android/guava-tests/test/com/google/common/util/concurrent/FuturesTransformAsyncTest.java

      }
    
      public void testFutureCancelBeforeInputCompletion() throws Exception {
        assertTrue(resultFuture.cancel(true));
        assertTrue(resultFuture.isCancelled());
        assertTrue(inputFuture.isCancelled());
        assertFalse(outputFuture.isCancelled());
        assertThrows(CancellationException.class, () -> resultFuture.get());
      }
    
      public void testFutureCancellableBeforeOutputCompletion() throws Exception {
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri Oct 18 22:10:29 UTC 2024
    - 6.2K bytes
    - Viewed (0)
  8. guava-tests/test/com/google/common/util/concurrent/FuturesTransformAsyncTest.java

      }
    
      public void testFutureCancelBeforeInputCompletion() throws Exception {
        assertTrue(resultFuture.cancel(true));
        assertTrue(resultFuture.isCancelled());
        assertTrue(inputFuture.isCancelled());
        assertFalse(outputFuture.isCancelled());
        assertThrows(CancellationException.class, () -> resultFuture.get());
      }
    
      public void testFutureCancellableBeforeOutputCompletion() throws Exception {
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri Oct 18 22:10:29 UTC 2024
    - 6.2K bytes
    - Viewed (0)
  9. android/guava-tests/test/com/google/common/util/concurrent/ListenableFutureTaskTest.java

        assertFalse(task.isCancelled());
    
        // Start the task to put it in the RUNNING state.  Have to use a separate
        // thread because the task will block on the task latch after unblocking
        // the run latch.
        exec.execute(task);
        runLatch.await();
        assertEquals(1, listenerLatch.getCount());
        assertFalse(task.isDone());
        assertFalse(task.isCancelled());
    
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri Oct 18 22:10:29 UTC 2024
    - 4.7K bytes
    - Viewed (0)
  10. guava-tests/test/com/google/common/util/concurrent/TrustedListenableFutureTaskTest.java

        assertTrue(task.isDone());
        assertFalse(task.isCancelled());
        assertEquals(2, getDone(task).intValue());
      }
    
      public void testCancelled() throws Exception {
        TrustedListenableFutureTask<Integer> task = TrustedListenableFutureTask.create(returning(2));
        assertFalse(task.isDone());
        task.cancel(false);
        assertTrue(task.isDone());
        assertTrue(task.isCancelled());
        assertFalse(task.wasInterrupted());
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Mon Oct 21 15:41:36 UTC 2024
    - 7.3K bytes
    - Viewed (0)
Back to top