Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 101 for Oancea (0.17 sec)

  1. android/guava/src/com/google/common/util/concurrent/TimeoutFuture.java

       * write.
       *
       * 2. visibility of the writes to an afterDone() call triggered by cancel():
       *
       * Since these fields are non-final that means that TimeoutFuture is not being 'safely published',
       * thus a motivated caller may be able to expose the reference to another thread that would then
       * call cancel() and be unable to cancel the delegate.
    Java
    - Registered: Fri Apr 26 12:43:10 GMT 2024
    - Last Modified: Thu Feb 01 21:46:34 GMT 2024
    - 7.7K bytes
    - Viewed (0)
  2. guava-gwt/src-super/com/google/common/util/concurrent/super/com/google/common/util/concurrent/AbstractFuture.java

        public final void addListener(Runnable listener, Executor executor) {
          super.addListener(listener, executor);
        }
    
        @CanIgnoreReturnValue
        @Override
        public final boolean cancel(boolean mayInterruptIfRunning) {
          return super.cancel(mayInterruptIfRunning);
        }
      }
    
      private static final Logger log = Logger.getLogger(AbstractFuture.class.getName());
    
      private State state;
      private V value;
    Java
    - Registered: Fri Apr 26 12:43:10 GMT 2024
    - Last Modified: Mon Jan 22 19:37:41 GMT 2024
    - 12.3K bytes
    - Viewed (0)
  3. android/guava-tests/test/com/google/common/util/concurrent/FuturesTest.java

      }
    
      private static void doTestSuccessfulAsList_resultCancelledRacingInputDone() throws Exception {
        // Simple (combined.cancel -> input.cancel -> setOneValue):
        successfulAsList(ImmutableList.of(SettableFuture.create())).cancel(true);
    
        /*
         * Complex (combined.cancel -> input.cancel -> other.set -> setOneValue),
         * to show that this isn't just about problems with the input future we just
         * cancelled:
    Java
    - Registered: Fri May 03 12:43:13 GMT 2024
    - Last Modified: Tue Feb 20 17:00:05 GMT 2024
    - 144.5K bytes
    - Viewed (0)
  4. android/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 May 03 12:43:13 GMT 2024
    - Last Modified: Wed Sep 06 18:30:30 GMT 2023
    - 6K bytes
    - Viewed (0)
  5. android/guava-tests/test/com/google/common/util/concurrent/TrustedListenableFutureTaskTest.java

      }
    
      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 {
          getDone(task);
          fail();
        } catch (CancellationException expected) {
        }
    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)
  6. src/main/java/jcifs/smb1/dcerpc/DcerpcConstants.java

        public static final int DCERPC_FIRST_FRAG      = 0x01; /* First fragment */
        public static final int DCERPC_LAST_FRAG       = 0x02; /* Last fragment */
        public static final int DCERPC_PENDING_CANCEL  = 0x04; /* Cancel was pending at sender */
        public static final int DCERPC_RESERVED_1      = 0x08;
        public static final int DCERPC_CONC_MPX        = 0x10; /* supports concurrent multiplexing */
    Java
    - Registered: Sun May 05 00:10:10 GMT 2024
    - Last Modified: Fri Mar 22 20:39:42 GMT 2019
    - 1.7K bytes
    - Viewed (0)
  7. android/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 May 03 12:43:13 GMT 2024
    - Last Modified: Tue Jul 16 17:22:27 GMT 2019
    - 3.6K bytes
    - Viewed (0)
  8. android/guava/src/com/google/common/util/concurrent/AggregateFuture.java

       * of {@link CombinedFuture}, the user-supplied callback usually has its own references to inputs.
       */
      /*
       * In certain circumstances, this field might theoretically not be visible to an afterDone() call
       * triggered by cancel(). For details, see the comments on the fields of TimeoutFuture.
       */
      @CheckForNull @LazyInit
      private ImmutableCollection<? extends ListenableFuture<? extends InputT>> futures;
    
      private final boolean allMustSucceed;
    Java
    - Registered: Fri Apr 26 12:43:10 GMT 2024
    - Last Modified: Thu Feb 01 21:46:34 GMT 2024
    - 15.4K bytes
    - Viewed (0)
  9. src/test/java/jcifs/tests/WatchTest.java

        @Override
        @After
        public void tearDown () throws Exception {
            if ( this.executor != null ) {
                this.executor.shutdown();
                if ( this.future != null ) {
                    this.future.cancel(true);
                }
                this.executor.awaitTermination(1, TimeUnit.SECONDS);
            }
            if ( this.base != null ) {
                this.base.delete();
            }
            super.tearDown();
        }
    Java
    - Registered: Sun May 05 00:10:10 GMT 2024
    - Last Modified: Sun Jul 01 13:12:10 GMT 2018
    - 8.4K bytes
    - Viewed (0)
  10. android/guava/src/com/google/common/util/concurrent/MoreExecutors.java

          }
    
          @Override
          public boolean cancel(boolean mayInterruptIfRunning) {
            boolean cancelled = super.cancel(mayInterruptIfRunning);
            if (cancelled) {
              // Unless it is cancelled, the delegate may continue being scheduled
              scheduledDelegate.cancel(mayInterruptIfRunning);
    
              // TODO(user): Cancel "this" if "scheduledDelegate" is cancelled.
            }
    Java
    - Registered: Fri Apr 26 12:43:10 GMT 2024
    - Last Modified: Wed Apr 17 16:33:44 GMT 2024
    - 41.8K bytes
    - Viewed (0)
Back to top