Search Options

Results per page
Sort
Preferred Languages
Advance

Results 61 - 70 of 84 for cartel (0.54 sec)

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

        }
    
        @Override
        public boolean isCancelled() {
          return sync.isCancelled();
        }
    
        @CanIgnoreReturnValue
        @Override
        public boolean cancel(boolean mayInterruptIfRunning) {
          if (!sync.cancel(mayInterruptIfRunning)) {
            return false;
          }
          executionList.execute();
          if (mayInterruptIfRunning) {
            interruptTask();
          }
          return true;
    Java
    - Registered: Fri Apr 12 12:43:09 GMT 2024
    - Last Modified: Wed May 09 15:17:25 GMT 2018
    - 13.6K bytes
    - Viewed (0)
  2. android/guava-tests/test/com/google/common/util/concurrent/AbstractFutureBenchmarks.java

        }
    
        @Override
        public boolean isCancelled() {
          return sync.isCancelled();
        }
    
        @CanIgnoreReturnValue
        @Override
        public boolean cancel(boolean mayInterruptIfRunning) {
          if (!sync.cancel(mayInterruptIfRunning)) {
            return false;
          }
          executionList.execute();
          if (mayInterruptIfRunning) {
            interruptTask();
          }
          return true;
    Java
    - Registered: Fri May 03 12:43:13 GMT 2024
    - Last Modified: Thu Apr 06 12:56:11 GMT 2023
    - 13.6K bytes
    - Viewed (0)
  3. guava-testlib/src/com/google/common/util/concurrent/testing/AbstractListenableFutureTest.java

        } catch (TimeoutException expected) {
        } finally {
          latch.countDown();
        }
      }
    
      /**
       * 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());
    
    Java
    - Registered: Fri Apr 19 12:43:09 GMT 2024
    - Last Modified: Wed Sep 06 18:30:30 GMT 2023
    - 6K bytes
    - Viewed (0)
  4. guava-tests/benchmark/com/google/common/util/concurrent/SingleThreadAbstractFutureBenchmark.java

          }
        }
        return r;
      }
    
      @Benchmark
      public long timeComplete_Cancel(int reps) throws Exception {
        long r = 0;
        List<Facade<Integer>> list = new ArrayList<>(reps);
        for (int i = 0; i < reps; i++) {
          final Facade<Integer> localFuture = impl.newFacade();
          list.add(localFuture);
          localFuture.cancel(false);
        }
        for (int i = 0; i < reps; i++) {
          Facade<Integer> facade = list.get(i);
    Java
    - Registered: Fri Apr 19 12:43:09 GMT 2024
    - Last Modified: Tue Jul 16 17:22:27 GMT 2019
    - 3.6K bytes
    - Viewed (0)
  5. guava-testlib/test/com/google/common/testing/GcFinalizationTest.java

        assertTrue(future.isDone());
        assertFalse(future.isCancelled());
      }
    
      public void testAwaitDone_Future_Cancel() {
        final SettableFuture<@Nullable Void> future = SettableFuture.create();
        Object x =
            new Object() {
              @Override
              protected void finalize() {
                future.cancel(false);
              }
            };
        x = null; // Hint to the JIT that x is unreachable
    Java
    - Registered: Fri Apr 19 12:43:09 GMT 2024
    - Last Modified: Wed Sep 06 17:04:31 GMT 2023
    - 7.4K bytes
    - Viewed (0)
  6. android/guava-testlib/test/com/google/common/testing/GcFinalizationTest.java

        assertTrue(future.isDone());
        assertFalse(future.isCancelled());
      }
    
      public void testAwaitDone_Future_Cancel() {
        final SettableFuture<@Nullable Void> future = SettableFuture.create();
        Object x =
            new Object() {
              @Override
              protected void finalize() {
                future.cancel(false);
              }
            };
        x = null; // Hint to the JIT that x is unreachable
    Java
    - Registered: Fri May 03 12:43:13 GMT 2024
    - Last Modified: Wed Sep 06 17:04:31 GMT 2023
    - 7.4K bytes
    - Viewed (0)
  7. guava-tests/test/com/google/common/util/concurrent/ClosingFutureFinishToFutureTest.java

        assertThatFutureBecomesCancelled(closingFuture.finishToFuture());
      }
    
      @Override
      void cancelFinalStepAndWait(ClosingFuture<TestCloseable> closingFuture) {
        assertThat(closingFuture.finishToFuture().cancel(false)).isTrue();
        waitUntilClosed(closingFuture);
        futureCancelled.countDown();
      }
    Java
    - Registered: Fri Apr 12 12:43:09 GMT 2024
    - Last Modified: Wed Sep 06 17:04:31 GMT 2023
    - 3.7K bytes
    - Viewed (0)
  8. guava-tests/benchmark/com/google/common/util/concurrent/AbstractFutureFootprintBenchmark.java

          AbstractFutureBenchmarks.awaitWaiting(thread);
        }
        switch (state) {
          case NOT_DONE:
            break;
          case FINISHED:
            f.set(null);
            break;
          case CANCELLED:
            f.cancel(false);
            break;
          case FAILED:
            f.setException(new Exception());
            break;
          default:
            throw new AssertionError();
        }
        return f;
      }
    Java
    - Registered: Fri Apr 19 12:43:09 GMT 2024
    - Last Modified: Wed Jan 17 15:34:54 GMT 2018
    - 3K bytes
    - Viewed (0)
  9. android/guava-tests/benchmark/com/google/common/util/concurrent/AbstractFutureFootprintBenchmark.java

          AbstractFutureBenchmarks.awaitWaiting(thread);
        }
        switch (state) {
          case NOT_DONE:
            break;
          case FINISHED:
            f.set(null);
            break;
          case CANCELLED:
            f.cancel(false);
            break;
          case FAILED:
            f.setException(new Exception());
            break;
          default:
            throw new AssertionError();
        }
        return f;
      }
    Java
    - Registered: Fri May 03 12:43:13 GMT 2024
    - Last Modified: Wed Jan 17 15:34:54 GMT 2018
    - 3K bytes
    - Viewed (0)
  10. guava-tests/test/com/google/common/util/concurrent/MoreExecutorsTest.java

        future = service.schedule(runnable, 5, TimeUnit.MINUTES);
        future.cancel(true);
        assertTrue(future.isCancelled());
        delegateFuture = (ScheduledFuture<?>) delegateQueue.element();
        assertTrue(delegateFuture.isCancelled());
    
        delegateQueue.clear();
    
        future = service.scheduleAtFixedRate(runnable, 5, 5, TimeUnit.MINUTES);
        future.cancel(true);
        assertTrue(future.isCancelled());
    Java
    - Registered: Fri Apr 12 12:43:09 GMT 2024
    - Last Modified: Wed Sep 06 17:04:31 GMT 2023
    - 28.2K bytes
    - Viewed (3)
Back to top