Search Options

Results per page
Sort
Preferred Languages
Advance

Results 201 - 210 of 1,889 for Batch (0.02 sec)

  1. src/test/java/jcifs/internal/smb2/Smb2SigningDigestTest.java

                            results[threadId] = data;
                        } finally {
                            latch.countDown();
                        }
                    });
                }
    
                assertTrue(latch.await(5, TimeUnit.SECONDS), "All threads should complete");
                executor.shutdown();
    
    Registered: Sun Sep 07 00:10:21 UTC 2025
    - Last Modified: Sat Aug 30 05:58:03 UTC 2025
    - 43.7K bytes
    - Viewed (0)
  2. android/guava-testlib/src/com/google/common/collect/testing/google/ReflectionFreeAssertThrows.java

                  + " map in that class.");
        }
        Object result;
        try {
          result = supplier.get();
        } catch (Throwable t) {
          if (predicate.apply(t)) {
            // We are careful to set up INSTANCE_OF to match each Predicate to its target Class.
            @SuppressWarnings("unchecked")
            T caught = (T) t;
            return caught;
          }
          throw new AssertionError(
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Thu Aug 07 16:05:33 UTC 2025
    - 6.3K bytes
    - Viewed (0)
  3. src/test/java/org/codelibs/fess/job/ExecJobTest.java

                }
                latch.countDown();
            });
    
            Thread t2 = new Thread(() -> {
                for (int i = 0; i < 100; i++) {
                    execJob.jvmOptions("-Xms" + i + "m");
                }
                latch.countDown();
            });
    
            t1.start();
            t2.start();
    
            assertTrue(latch.await(5, TimeUnit.SECONDS));
    Registered: Thu Sep 04 12:52:25 UTC 2025
    - Last Modified: Tue Aug 19 14:09:36 UTC 2025
    - 24.5K bytes
    - Viewed (0)
  4. src/test/java/org/codelibs/fess/mylasta/action/FessLabelsTest.java

                TestFessLabels labels = new TestFessLabels();
                labels.testAssertPropertyNotNull(null);
                fail("Should throw IllegalArgumentException");
            } catch (IllegalArgumentException e) {
                assertEquals("The argument 'property' for message should not be null.", e.getMessage());
            }
        }
    
        /**
    Registered: Thu Sep 04 12:52:25 UTC 2025
    - Last Modified: Tue Aug 19 14:09:36 UTC 2025
    - 13.8K bytes
    - Viewed (0)
  5. src/test/java/org/codelibs/fess/mylasta/action/FessHtmlPathTest.java

                HtmlNext htmlNext = (HtmlNext) baseField.get(null);
                assertTrue("Base path should match pattern", htmlNext.getRoutingPath().startsWith(basePath));
            }
    
            if (detailsField != null) {
                HtmlNext htmlNext = (HtmlNext) detailsField.get(null);
                assertTrue("Details path should match pattern", htmlNext.getRoutingPath().contains("_details.jsp"));
            }
    
            if (editField != null) {
    Registered: Thu Sep 04 12:52:25 UTC 2025
    - Last Modified: Tue Aug 19 14:09:36 UTC 2025
    - 12.9K bytes
    - Viewed (0)
  6. guava-testlib/src/com/google/common/testing/ArbitraryInstances.java

          constructor = type.getConstructor();
        } catch (NoSuchMethodException e) {
          return arbitraryConstantInstanceOrNull(type);
        }
        constructor.setAccessible(true); // accessibility check is too slow
        try {
          return constructor.newInstance();
        } catch (InstantiationException | IllegalAccessException impossible) {
          throw new AssertionError(impossible);
        } catch (InvocationTargetException e) {
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Wed Jul 16 17:42:14 UTC 2025
    - 21.4K bytes
    - Viewed (0)
  7. android/guava-testlib/src/com/google/common/collect/testing/testers/ReflectionFreeAssertThrows.java

                  + " map in that class.");
        }
        Object result;
        try {
          result = supplier.get();
        } catch (Throwable t) {
          if (predicate.apply(t)) {
            // We are careful to set up INSTANCE_OF to match each Predicate to its target Class.
            @SuppressWarnings("unchecked")
            T caught = (T) t;
            return caught;
          }
          throw new AssertionError(
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Thu Aug 07 16:05:33 UTC 2025
    - 6.9K bytes
    - Viewed (0)
  8. okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/connection/RealConnection.kt

        if (address.url.host ==
          this
            .route()
            .address.url.host
        ) {
          return true // This connection is a perfect match.
        }
    
        // At this point we don't have a hostname match. But we still be able to carry the request if
        // our connection coalescing requirements are met. See also:
        // https://hpbn.co/optimizing-application-delivery/#eliminate-domain-sharding
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Thu Jul 31 04:18:40 UTC 2025
    - 14.9K bytes
    - Viewed (0)
  9. src/main/java/org/codelibs/fess/app/web/admin/dict/stemmeroverride/AdminDictStemmeroverrideAction.java

            return stemmerOverrideService.getStemmerOverrideFile(form.dictId).map(file -> {
                try (InputStream inputStream = form.stemmerOverrideFile.getInputStream()) {
                    file.update(inputStream);
                } catch (final IOException e) {
                    logger.warn("Failed to process a request.", e);
                    throwValidationError(messages -> messages.addErrorsFailedToUploadStemmeroverrideFile(GLOBAL),
    Registered: Thu Sep 04 12:52:25 UTC 2025
    - Last Modified: Thu Aug 07 03:06:29 UTC 2025
    - 23.5K bytes
    - Viewed (0)
  10. android/guava/src/com/google/common/io/CharSource.java

       * @throws IOException if an I/O error occurs while opening the stream
       * @since 33.4.0 (but since 22.0 in the JRE flavor)
       */
      @MustBeClosed
      // If users use this when they shouldn't, we hope that NewApi will catch subsequent Stream calls.
      @IgnoreJRERequirement
      public Stream<String> lines() throws IOException {
        BufferedReader reader = openBufferedStream();
        return reader.lines().onClose(() -> closeUnchecked(reader));
      }
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Wed Jul 16 17:42:14 UTC 2025
    - 25.7K bytes
    - Viewed (0)
Back to top