Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 1 - 10 of 591 for finally (0.04 seconds)

  1. guava-tests/benchmark/com/google/common/util/concurrent/MonitorBasedArrayBlockingQueue.java

       * found in any textbook.
       */
    
      /** Monitor guarding all access */
      final Monitor monitor;
    
      /** Guard for waiting takes */
      private final Monitor.Guard notEmpty;
    
      /** Guard for waiting puts */
      private final Monitor.Guard notFull;
    
      // Internal helper methods
    
      /** Circularly increment i. */
      final int inc(int i) {
        return (++i == items.length) ? 0 : i;
      }
    
      /**
    Created: Fri Dec 26 12:43:10 GMT 2025
    - Last Modified: Tue May 13 18:46:00 GMT 2025
    - 22.4K bytes
    - Click Count (0)
  2. android/guava-tests/benchmark/com/google/common/util/concurrent/MonitorBasedPriorityBlockingQueue.java

      // http://gee.cs.oswego.edu/cgi-bin/viewcvs.cgi/jsr166/src/main/java/util/concurrent/
    
      private static final long serialVersionUID = 5595510919245408276L;
    
      final PriorityQueue<E> q;
      final Monitor monitor = new Monitor(true);
      private final Monitor.Guard notEmpty =
          new Monitor.Guard(monitor) {
            @Override
            public boolean isSatisfied() {
              return !q.isEmpty();
    Created: Fri Dec 26 12:43:10 GMT 2025
    - Last Modified: Tue May 13 18:46:00 GMT 2025
    - 18.9K bytes
    - Click Count (0)
  3. android/guava/src/com/google/common/util/concurrent/AbstractService.java

            notifyFailed(shutdownFailure);
          } finally {
            monitor.leave();
            dispatchListenerEvents();
          }
        }
        return this;
      }
    
      @Override
      public final void awaitRunning() {
        monitor.enterWhenUninterruptibly(hasReachedRunning);
        try {
          checkCurrentState(RUNNING);
        } finally {
          monitor.leave();
        }
      }
    
      @Override
    Created: Fri Dec 26 12:43:10 GMT 2025
    - Last Modified: Wed Feb 19 21:24:11 GMT 2025
    - 20.3K bytes
    - Click Count (0)
  4. android/guava/src/com/google/common/util/concurrent/CycleDetectingLockFactory.java

        public void unlock() {
          try {
            super.unlock();
          } finally {
            lockStateChanged(readWriteLock);
          }
        }
      }
    
      private final class CycleDetectingReentrantWriteLock extends ReentrantReadWriteLock.WriteLock {
    
        @Weak final CycleDetectingReentrantReadWriteLock readWriteLock;
    
        CycleDetectingReentrantWriteLock(CycleDetectingReentrantReadWriteLock readWriteLock) {
    Created: Fri Dec 26 12:43:10 GMT 2025
    - Last Modified: Thu Sep 11 17:06:34 GMT 2025
    - 35.9K bytes
    - Click Count (0)
  5. android/guava/src/com/google/common/util/concurrent/Uninterruptibles.java

        try {
          while (true) {
            try {
              latch.await();
              return;
            } catch (InterruptedException e) {
              interrupted = true;
            }
          }
        } finally {
          if (interrupted) {
            Thread.currentThread().interrupt();
          }
        }
      }
    
      /**
       * Invokes {@code latch.}{@link CountDownLatch#await(long, TimeUnit) await(timeout, unit)}
    Created: Fri Dec 26 12:43:10 GMT 2025
    - Last Modified: Thu Aug 07 16:05:33 GMT 2025
    - 19.8K bytes
    - Click Count (0)
  6. android/guava-tests/test/com/google/common/io/CloserTest.java

        private final List<Suppression> suppressions = new ArrayList<>();
    
        @Override
        public void suppress(Closeable closeable, Throwable thrown, Throwable suppressed) {
          suppressions.add(new Suppression(closeable, thrown, suppressed));
        }
      }
    
      /** Record of a call to suppress. */
      private static class Suppression {
        private final Closeable closeable;
    Created: Fri Dec 26 12:43:10 GMT 2025
    - Last Modified: Tue Oct 28 16:03:47 GMT 2025
    - 11.8K bytes
    - Click Count (0)
  7. guava/src/com/google/common/util/concurrent/CycleDetectingLockFactory.java

        public void unlock() {
          try {
            super.unlock();
          } finally {
            lockStateChanged(readWriteLock);
          }
        }
      }
    
      private final class CycleDetectingReentrantWriteLock extends ReentrantReadWriteLock.WriteLock {
    
        @Weak final CycleDetectingReentrantReadWriteLock readWriteLock;
    
        CycleDetectingReentrantWriteLock(CycleDetectingReentrantReadWriteLock readWriteLock) {
    Created: Fri Dec 26 12:43:10 GMT 2025
    - Last Modified: Thu Sep 11 17:06:34 GMT 2025
    - 35.9K bytes
    - Click Count (0)
  8. guava/src/com/google/common/util/concurrent/AbstractService.java

            notifyFailed(shutdownFailure);
          } finally {
            monitor.leave();
            dispatchListenerEvents();
          }
        }
        return this;
      }
    
      @Override
      public final void awaitRunning() {
        monitor.enterWhenUninterruptibly(hasReachedRunning);
        try {
          checkCurrentState(RUNNING);
        } finally {
          monitor.leave();
        }
      }
    
      /**
    Created: Fri Dec 26 12:43:10 GMT 2025
    - Last Modified: Wed Feb 19 21:24:11 GMT 2025
    - 20.7K bytes
    - Click Count (0)
  9. android/guava/src/com/google/common/io/CharSource.java

            return seq.length();
          } catch (Throwable e) {
            throw closer.rethrow(e);
          } finally {
            closer.close();
          }
        }
      }
    
      private static final class EmptyCharSource extends StringCharSource {
    
        private static final EmptyCharSource INSTANCE = new EmptyCharSource();
    
        private EmptyCharSource() {
          super("");
        }
    
        @Override
    Created: Fri Dec 26 12:43:10 GMT 2025
    - Last Modified: Mon Sep 08 18:35:13 GMT 2025
    - 25.7K bytes
    - Click Count (0)
  10. guava/src/com/google/common/io/CharSource.java

            return seq.length();
          } catch (Throwable e) {
            throw closer.rethrow(e);
          } finally {
            closer.close();
          }
        }
      }
    
      private static final class EmptyCharSource extends StringCharSource {
    
        private static final EmptyCharSource INSTANCE = new EmptyCharSource();
    
        private EmptyCharSource() {
          super("");
        }
    
        @Override
    Created: Fri Dec 26 12:43:10 GMT 2025
    - Last Modified: Mon Sep 08 18:35:13 GMT 2025
    - 25.3K bytes
    - Click Count (0)
Back to Top