Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 1,145 for finally (0.11 sec)

  1. 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)}
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Sat Oct 19 00:51:36 UTC 2024
    - 19.1K bytes
    - Viewed (0)
  2. fess-crawler/src/main/java/org/codelibs/fess/crawler/extractor/impl/TikaExtractor.java

                }
            } catch (final TikaException e) {
                throw e;
            } catch (final Exception e) {
                throw new ExtractException("Failed to read a content.", e);
            } finally {
                FileUtil.deleteInBackground(tempFile);
            }
        }
    
        protected Metadata createMetadata(final String resourceName, final String contentType, final String contentEncoding,
    Registered: Sun Nov 10 03:50:12 UTC 2024
    - Last Modified: Sat Oct 12 01:41:37 UTC 2024
    - 25K bytes
    - Viewed (0)
  3. guava-testlib/test/com/google/common/testing/GcFinalizationTest.java

      class Interruptenator extends Thread {
        final AtomicBoolean shutdown;
    
        Interruptenator(final Thread interruptee) {
          this(interruptee, new AtomicBoolean(false));
        }
    
        @SuppressWarnings("ThreadPriorityCheck") // TODO: b/175898629 - Consider onSpinWait.
        Interruptenator(final Thread interruptee, final AtomicBoolean shutdown) {
          super(
              new Runnable() {
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Thu Oct 17 02:42:09 UTC 2024
    - 7.9K bytes
    - Viewed (0)
  4. 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)}
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Sat Oct 19 00:51:36 UTC 2024
    - 20.1K bytes
    - Viewed (0)
  5. 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
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Thu Oct 31 14:20:11 UTC 2024
    - 25.5K bytes
    - Viewed (0)
  6. src/main/java/org/codelibs/fess/helper/ProcessHelper.java

        }
    
        public JobProcess startProcess(final String sessionId, final List<String> cmdList, final Consumer<ProcessBuilder> pbCall) {
            return startProcess(sessionId, cmdList, pbCall, InputStreamThread.MAX_BUFFER_SIZE, null);
        }
    
        public synchronized JobProcess startProcess(final String sessionId, final List<String> cmdList, final Consumer<ProcessBuilder> pbCall,
                final int bufferSize, final Consumer<String> outputCallback) {
    Registered: Thu Oct 31 13:40:30 UTC 2024
    - Last Modified: Fri Oct 11 21:20:39 UTC 2024
    - 6.4K bytes
    - Viewed (0)
  7. fess-crawler-opensearch/src/test/java/org/codelibs/fess/crawler/CrawlerTest.java

            final CrawlerWebServer server2 = new CrawlerWebServer(7071);
            server2.start();
    
            final String url1 = "http://localhost:7070/";
            final String url2 = "http://localhost:7071/";
            try {
                final int maxCount = 10;
                final int numOfThread = 10;
    
                final File file = File.createTempFile("crawler-", "");
                file.delete();
                file.mkdirs();
    Registered: Sun Nov 10 03:50:12 UTC 2024
    - Last Modified: Thu Nov 07 04:44:10 UTC 2024
    - 7.7K bytes
    - Viewed (0)
  8. guava-tests/test/com/google/common/util/concurrent/TrustedListenableFutureTaskTest.java

      }
    
      @J2ktIncompatible
      @GwtIncompatible // blocking wait
      public void testCancel_interrupted() throws Exception {
        final AtomicBoolean interruptedExceptionThrown = new AtomicBoolean();
        final CountDownLatch enterLatch = new CountDownLatch(1);
        final CountDownLatch exitLatch = new CountDownLatch(1);
        final TrustedListenableFutureTask<Integer> task =
            TrustedListenableFutureTask.create(
                new Callable<Integer>() {
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Mon Oct 21 15:41:36 UTC 2024
    - 7.3K bytes
    - Viewed (0)
  9. android/guava-testlib/test/com/google/common/testing/GcFinalizationTest.java

      class Interruptenator extends Thread {
        final AtomicBoolean shutdown;
    
        Interruptenator(final Thread interruptee) {
          this(interruptee, new AtomicBoolean(false));
        }
    
        @SuppressWarnings("ThreadPriorityCheck") // TODO: b/175898629 - Consider onSpinWait.
        Interruptenator(final Thread interruptee, final AtomicBoolean shutdown) {
          super(
              new Runnable() {
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Thu Oct 17 02:42:09 UTC 2024
    - 7.9K bytes
    - Viewed (0)
  10. compat/maven-model-builder/src/main/java/org/apache/maven/model/validation/DefaultModelValidator.java

        private static final String ILLEGAL_FS_CHARS = "\\/:\"<>|?*";
    
        private static final String ILLEGAL_VERSION_CHARS = ILLEGAL_FS_CHARS;
    
        private static final String ILLEGAL_REPO_ID_CHARS = ILLEGAL_FS_CHARS;
    
        private static final String EMPTY = "";
    
        private record ActivationFrame(String location, Optional<? extends InputLocationTracker> parent) {}
    Registered: Sun Nov 03 03:35:11 UTC 2024
    - Last Modified: Fri Oct 25 12:31:46 UTC 2024
    - 77.1K bytes
    - Viewed (0)
Back to top