Search Options

Results per page
Sort
Preferred Languages
Advance

Results 131 - 140 of 1,833 for batch (0.02 sec)

  1. src/main/java/org/codelibs/fess/app/web/admin/keymatch/AdminKeymatchAction.java

        //                                                                           =========
        /** Helper for key match operations. */
        @Resource
        private KeyMatchHelper keyMatchHelper;
    
        /** Service for key match operations. */
        @Resource
        private KeyMatchService keyMatchService;
    
        /** Pager for key match list pagination. */
        @Resource
        private KeyMatchPager keyMatchPager;
    
    Registered: Thu Sep 04 12:52:25 UTC 2025
    - Last Modified: Thu Jul 17 08:28:31 UTC 2025
    - 16.7K bytes
    - Viewed (0)
  2. android/guava/src/com/google/common/util/concurrent/Uninterruptibles.java

      /** Invokes {@code latch.}{@link CountDownLatch#await() await()} uninterruptibly. */
      @J2ktIncompatible
      @GwtIncompatible // concurrency
      public static void awaitUninterruptibly(CountDownLatch latch) {
        boolean interrupted = false;
        try {
          while (true) {
            try {
              latch.await();
              return;
            } catch (InterruptedException e) {
              interrupted = true;
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Thu Aug 07 16:05:33 UTC 2025
    - 19.8K bytes
    - Viewed (0)
  3. src/test/java/org/codelibs/fess/validation/CustomSizeTest.java

            final CustomSize annotation = field.getAnnotation(CustomSize.class);
    
            assertNotNull("Annotation should be present on field", annotation);
            assertEquals("minKey should match", "test.min", annotation.minKey());
            assertEquals("maxKey should match", "test.max", annotation.maxKey());
            assertEquals("message should be default", "{jakarta.validation.constraints.Size.message}", annotation.message());
        }
    
    Registered: Thu Sep 04 12:52:25 UTC 2025
    - Last Modified: Tue Aug 19 14:09:36 UTC 2025
    - 17.2K bytes
    - Viewed (0)
  4. guava-testlib/src/com/google/common/testing/GcFinalization.java

        do {
          System.runFinalization();
          if (latch.getCount() == 0) {
            return;
          }
          System.gc();
          try {
            if (latch.await(1L, SECONDS)) {
              return;
            }
          } catch (InterruptedException ie) {
            throw new RuntimeException("Unexpected interrupt while waiting for latch", ie);
          }
        } while (System.nanoTime() - deadline < 0);
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Mon Mar 17 20:26:29 UTC 2025
    - 11.5K bytes
    - Viewed (0)
  5. compat/maven-compat/src/main/java/org/apache/maven/artifact/resolver/DefaultArtifactResolver.java

                        executor.execute(new ResolveTask(
                                classLoader, latch, artifact, session, node.getRemoteRepositories(), result));
                    } else {
                        latch.countDown();
                    }
                }
                try {
                    latch.await();
                } catch (InterruptedException e) {
                    result.addErrorArtifactException(
    Registered: Sun Sep 07 03:35:12 UTC 2025
    - Last Modified: Fri Jun 06 14:28:57 UTC 2025
    - 25K bytes
    - Viewed (0)
  6. compat/maven-compat/src/main/java/org/apache/maven/repository/DefaultMirrorSelector.java

         * <li>{@code *,!repo1} = everything except {@code repo1}.</li>
         * </ul>
         *
         * @param originalRepository to compare for a match.
         * @param pattern used for match.
         * @return true if the repository is a match to this pattern.
         */
        static boolean matchPattern(ArtifactRepository originalRepository, String pattern) {
            boolean result = false;
    Registered: Sun Sep 07 03:35:12 UTC 2025
    - Last Modified: Fri Jun 06 14:28:57 UTC 2025
    - 8K bytes
    - Viewed (0)
  7. okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/tls/OkHostnameVerifier.kt

        }
    
        // Optimization: check whether hostname is too short to match the pattern. hostName must be at
        // least as long as the pattern because asterisk must match the whole left-most label and
        // hostname starts with a non-empty label. Thus, asterisk has to match one or more characters.
        if (hostname.length < pattern.length) {
          return false // Hostname too short to match the pattern.
        }
    
        if ("*." == pattern) {
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Wed Mar 19 19:25:20 UTC 2025
    - 7.6K bytes
    - Viewed (0)
  8. src/test/java/jcifs/SmbWatchHandleTest.java

            // Execute and verify
            CIFSException thrown = assertThrows(CIFSException.class, () -> {
                watchHandle.watch();
            });
    
            assertEquals("Watch operation failed", thrown.getMessage());
            verify(watchHandle, times(1)).watch();
        }
    
        /**
         * Test call() method delegates to watch()
         */
        @Test
    Registered: Sun Sep 07 00:10:21 UTC 2025
    - Last Modified: Thu Aug 14 05:31:44 UTC 2025
    - 13.2K bytes
    - Viewed (0)
  9. src/main/java/org/codelibs/fess/helper/ProcessHelper.java

                    } catch (final Exception e) {
                        logger.warn("Could not close a process error stream.", e);
                    } finally {
                        latch.countDown();
                    }
                }, "ProcessCloser-error-" + sessionId).start();
                new Thread(() -> {
                    try {
                        CloseableUtil.closeQuietly(process.getOutputStream());
                    } catch (final Exception e) {
    Registered: Thu Sep 04 12:52:25 UTC 2025
    - Last Modified: Thu Jul 17 08:28:31 UTC 2025
    - 9.8K bytes
    - Viewed (0)
  10. src/main/java/org/codelibs/fess/exec/SuggestCreator.java

                    exitCode.set(1);
                    latch.countDown();
                });
    
                try {
                    latch.await();
                } catch (final InterruptedException ignore) {
                    if (logger.isDebugEnabled()) {
                        logger.debug("Interrupted.", ignore);
                    }
                    exitCode.set(1);
                }
            }
    
    Registered: Thu Sep 04 12:52:25 UTC 2025
    - Last Modified: Thu Aug 07 03:06:29 UTC 2025
    - 11K bytes
    - Viewed (0)
Back to top