Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 111 - 120 of 2,176 for latch (0.04 seconds)

The search processing time has exceeded the limit. The displayed results may be partial.

  1. android/guava-testlib/src/com/google/common/util/concurrent/testing/MockFutureListener.java

       *     result doesn't match the expected value.
       */
      public void assertSuccess(Object expectedData) throws Throwable {
        // Verify that the listener executed in a reasonable amount of time.
        Assert.assertTrue(countDownLatch.await(1L, SECONDS));
    
        try {
          Assert.assertEquals(expectedData, future.get());
        } catch (ExecutionException e) {
          throw e.getCause();
        }
      }
    
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Fri May 12 18:12:42 GMT 2023
    - 3K bytes
    - Click Count (0)
  2. apache-maven/src/assembly/maven/bin/JvmConfigParser.java

    import java.nio.file.Files;
    import java.nio.file.Path;
    import java.nio.file.Paths;
    import java.util.ArrayList;
    import java.util.List;
    
    /**
     * Parses .mvn/jvm.config file for Windows batch/Unix shell scripts.
     * This avoids the complexity of parsing special characters (pipes, quotes, etc.) in scripts.
     *
     * Usage: java JvmConfigParser.java <jvm.config-path> <maven-project-basedir> [output-file]
     *
    Created: Sun Apr 05 03:35:12 GMT 2026
    - Last Modified: Wed Dec 10 16:40:06 GMT 2025
    - 6.4K bytes
    - Click Count (0)
  3. src/main/webapp/js/purify.min.js

    return e.createPolicy(r,{createHTML:e=>e,createScriptURL:e=>e})}catch(e){return console.warn("TrustedTypes policy "+r+" could not be created."),null}}(j,c)),null!==le&&"string"==typeof ce&&(ce=le.createHTML(""));i&&i(e),dt=e}},yt=R({},[...k,...x,...L]),Et=R({},[...I,...M]),At=function(e){f(o.removed,{element:e});try{ae(e).removeChild(e)}catch(t){V(e)}},_t=function(e,t){try{f(o.removed,{attribute:t.getAttributeNode(e),from:t})}catch(e){f(o.removed,{attribute:null,from:t})}if(t.removeAttribute(e),...
    Created: Tue Mar 31 13:07:34 GMT 2026
    - Last Modified: Sun Mar 15 06:21:57 GMT 2026
    - 22.7K bytes
    - Click Count (0)
  4. fess-crawler/src/main/java/org/codelibs/fess/crawler/CrawlerThread.java

                            } catch (final Exception e1) {
                                log(logHelper, LogType.CRAWLING_EXCEPTION, crawlerContext, urlQueue, e1);
                            }
                            if (noWaitOnFolder) {
                                continue;
                            }
                        } catch (final CrawlingAccessException e) {
    Created: Sun Apr 12 03:50:13 GMT 2026
    - Last Modified: Wed Dec 31 09:07:38 GMT 2025
    - 20.3K bytes
    - Click Count (0)
  5. src/test/java/org/codelibs/fess/helper/RelatedContentHelperTest.java

            List<RelatedContent> testData = new ArrayList<>();
            testData.add(createRelatedContent("exact", "Exact Match", ""));
            testData.add(createRelatedContent("regex:test.*", "Regex Match: __QUERY__", ""));
            mockBhv.setTestData(testData);
    
            relatedContentHelper.load();
    
            // Test exact match
            String[] results = relatedContentHelper.getRelatedContents("exact");
            assertEquals(1, results.length);
    Created: Tue Mar 31 13:07:34 GMT 2026
    - Last Modified: Wed Jan 14 14:29:07 GMT 2026
    - 14.6K bytes
    - Click Count (0)
  6. src/test/java/org/codelibs/fess/helper/IntervalControlHelperTest.java

                fail("Should throw FessSystemException");
            } catch (FessSystemException e) {
                assertEquals("Invalid time format: 12. Expected format: HH:MM", e.getMessage());
            }
    
            try {
                IntervalControlHelper.parseTime("12:30:45");
                fail("Should throw FessSystemException");
            } catch (FessSystemException e) {
    Created: Tue Mar 31 13:07:34 GMT 2026
    - Last Modified: Wed Jan 14 14:29:07 GMT 2026
    - 13.6K bytes
    - Click Count (0)
  7. guava-tests/test/com/google/common/util/concurrent/TestThread.java

            try {
              result = invokeMethod(request.methodName, request.arguments);
            } catch (ThreadDeath death) {
              return;
            } catch (InvocationTargetException exception) {
              responseQueue.put(new Response(request.methodName, null, exception.getTargetException()));
              continue;
            } catch (Throwable throwable) {
              responseQueue.put(new Response(request.methodName, null, throwable));
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Fri Mar 13 13:01:07 GMT 2026
    - 11.5K bytes
    - Click Count (0)
  8. src/main/webapp/css/admin/respond.min.js

    unction(a,b,d){var e=a.replace(c.regex.keyframes,"").match(c.regex.media),f=e&&e.length||0;b=b.substring(0,b.lastIndexOf("/"));var g=function(a){return a.replace(c.regex.urls,"$1"+b+"$2$3")},h=!f&&d;b.length&&(b+="/"),h&&(f=1);for(var i=0;f>i;i++){var j,k,n,o;h?(j=d,m.push(g(a))):(j=e[i].match(c.regex.findStyles)&&RegExp.$1,m.push(RegExp.$2&&g(RegExp.$2))),n=j.split(","),o=n.length;for(var p=0;o>p;p++)k=n[p],l.push({media:k.split("(")[0].match(c.regex.only)&&RegExp.$2||"all",rules:m.length-1,has...
    Created: Tue Mar 31 13:07:34 GMT 2026
    - Last Modified: Thu Oct 08 12:14:13 GMT 2015
    - 4.3K bytes
    - Click Count (0)
  9. src/test/java/jcifs/smb/DirFileEntryEnumIterator1Test.java

            List<String[]> batches = new ArrayList<>();
            batches.add(new String[] { ".", "..", "a", "b" }); // first batch, dot entries filtered
            batches.add(new String[] { "c" }); // second batch
            batches.add(new String[] {}); // last -> NO_MORE_FILES
    
            // send() answer that mutates the provided response
    Created: Sun Apr 05 00:10:12 GMT 2026
    - Last Modified: Thu Aug 14 05:31:44 GMT 2025
    - 12.7K bytes
    - Click Count (0)
  10. android/guava/src/com/google/common/util/concurrent/FuturesGetChecked.java

        bestGetCheckedTypeValidator().validateClass(exceptionClass);
        try {
          return future.get(timeout, unit);
        } catch (InterruptedException e) {
          currentThread().interrupt();
          throw newWithCause(exceptionClass, e);
        } catch (TimeoutException e) {
          throw newWithCause(exceptionClass, e);
        } catch (ExecutionException e) {
          wrapAndThrowExceptionOrError(e.getCause(), exceptionClass);
          throw new AssertionError();
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Sat Aug 09 01:14:59 GMT 2025
    - 10.2K bytes
    - Click Count (0)
Back to Top