Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 27 for isCanceled (0.27 sec)

  1. src/main/java/org/codelibs/core/timer/TimeoutTask.java

         * @return 永続的かどうか
         */
        public boolean isPermanent() {
            return permanent;
        }
    
        /**
         * キャンセルされているかどうかを返します。
         *
         * @return キャンセルされているか
         */
        public boolean isCanceled() {
            return status == CANCELED;
        }
    
        /**
         * キャンセルします。
         */
        public void cancel() {
            status = CANCELED;
        }
    
        /**
         * 止まっているかどうか返します。
         *
    Java
    - Registered: Fri May 03 20:58:11 GMT 2024
    - Last Modified: Thu Mar 07 01:59:08 GMT 2024
    - 2.7K bytes
    - Viewed (0)
  2. src/main/java/org/codelibs/fess/job/PythonJob.java

                logger.warn("Failed to run python command.", e);
                resultBuf.append(e.getMessage()).append("\n");
            } finally {
                if (timeoutTask != null && !timeoutTask.isCanceled()) {
                    timeoutTask.cancel();
                }
            }
    
            return resultBuf.toString();
    
        }
    
        protected void executePython() {
    Java
    - Registered: Mon May 06 08:04:11 GMT 2024
    - Last Modified: Thu Feb 22 01:37:57 GMT 2024
    - 5.9K bytes
    - Viewed (0)
  3. src/main/java/org/codelibs/core/timer/TimeoutManager.java

            }
            for (SLinkedList<TimeoutTask>.Entry e = timeoutTaskList.getFirstEntry(); e != null; e = e.getNext()) {
                final TimeoutTask task = e.getElement();
                if (task.isCanceled()) {
                    e.remove();
                } else if (!task.isStopped() && task.isExpired()) {
                    expiredTask.add(task);
                    if (!task.isPermanent()) {
                        e.remove();
    Java
    - Registered: Fri May 03 20:58:11 GMT 2024
    - Last Modified: Thu Mar 07 01:59:08 GMT 2024
    - 8K bytes
    - Viewed (0)
  4. guava-tests/test/com/google/common/util/concurrent/ListenableFutureTester.java

        assertFalse(future.isCancelled());
    
        assertEquals(expectedValue, future.get());
      }
    
      public void testCancelledFuture() throws InterruptedException, ExecutionException {
        assertTrue(future.isDone());
        assertTrue(future.isCancelled());
    
        assertTrue(latch.await(5, TimeUnit.SECONDS));
        assertTrue(future.isDone());
        assertTrue(future.isCancelled());
    
        assertThrows(CancellationException.class, () -> future.get());
    Java
    - Registered: Fri Apr 12 12:43:09 GMT 2024
    - Last Modified: Wed Sep 06 17:04:31 GMT 2023
    - 3.3K bytes
    - Viewed (0)
  5. android/guava-tests/test/com/google/common/util/concurrent/ListenableFutureTester.java

        assertFalse(future.isCancelled());
    
        assertEquals(expectedValue, future.get());
      }
    
      public void testCancelledFuture() throws InterruptedException, ExecutionException {
        assertTrue(future.isDone());
        assertTrue(future.isCancelled());
    
        assertTrue(latch.await(5, TimeUnit.SECONDS));
        assertTrue(future.isDone());
        assertTrue(future.isCancelled());
    
        assertThrows(CancellationException.class, () -> future.get());
    Java
    - Registered: Fri May 03 12:43:13 GMT 2024
    - Last Modified: Wed Sep 06 17:04:31 GMT 2023
    - 3.3K bytes
    - Viewed (0)
  6. android/guava-testlib/src/com/google/common/util/concurrent/testing/AbstractListenableFutureTest.java

      }
    
      /**
       * Tests that a canceled future throws a cancellation exception.
       *
       * <p>This method checks the cancel, isCancelled, and isDone methods.
       */
      public void testCanceledFutureThrowsCancellation() throws Exception {
    
        assertFalse(future.isDone());
        assertFalse(future.isCancelled());
    
        CountDownLatch successLatch = new CountDownLatch(1);
    
    Java
    - Registered: Fri May 03 12:43:13 GMT 2024
    - Last Modified: Wed Sep 06 18:30:30 GMT 2023
    - 6K bytes
    - Viewed (0)
  7. android/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());
        try {
    Java
    - Registered: Fri May 03 12:43:13 GMT 2024
    - Last Modified: Tue Feb 13 14:28:25 GMT 2024
    - 7.3K 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 {
    Java
    - Registered: Fri Apr 12 12:43:09 GMT 2024
    - Last Modified: Wed Sep 06 17:04:31 GMT 2023
    - 6.1K bytes
    - Viewed (0)
  9. 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());
    
    Java
    - Registered: Fri Apr 12 12:43:09 GMT 2024
    - Last Modified: Wed Sep 06 17:04:31 GMT 2023
    - 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());
        try {
    Java
    - Registered: Fri Apr 12 12:43:09 GMT 2024
    - Last Modified: Tue Feb 13 14:28:25 GMT 2024
    - 7.3K bytes
    - Viewed (0)
Back to top