Search Options

Results per page
Sort
Preferred Languages
Advance

Results 61 - 70 of 109 for currentThread (0.3 sec)

  1. src/main/java/org/codelibs/fess/suggest/settings/BadWordSettings.java

                return;
            }
    
            final List<String> list = new ArrayList<>();
            try (BufferedReader br = new BufferedReader(new InputStreamReader(
                    Thread.currentThread().getContextClassLoader().getResourceAsStream("suggest_settings/default-badwords.txt")))) {
    
                String line;
                while ((line = br.readLine()) != null) {
    Registered: Fri Nov 08 09:08:12 UTC 2024
    - Last Modified: Sat Oct 12 00:10:39 UTC 2024
    - 4.3K bytes
    - Viewed (0)
  2. okhttp/src/main/kotlin/okhttp3/internal/publicsuffix/PublicSuffixDatabase.kt

          readTheListUninterruptibly()
        } else {
          try {
            readCompleteLatch.await()
          } catch (_: InterruptedException) {
            Thread.currentThread().interrupt() // Retain interrupted status.
          }
        }
    
        check(::publicSuffixListBytes.isInitialized) {
          // May have failed with an IOException
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon Jan 08 01:13:22 UTC 2024
    - 11.7K bytes
    - Viewed (0)
  3. android/guava-tests/test/com/google/common/util/concurrent/ExecutionListTest.java

        list.add(
            new Runnable() {
              @Override
              public void run() {
                try {
                  okayToRun.await();
                } catch (InterruptedException e) {
                  Thread.currentThread().interrupt();
                  throw new RuntimeException(e);
                }
                runCalled.getAndIncrement();
              }
            },
            directExecutor());
        Runnable execute =
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri Oct 18 22:10:29 UTC 2024
    - 4.7K bytes
    - Viewed (0)
  4. guava-tests/test/com/google/common/util/concurrent/ExecutionListTest.java

        list.add(
            new Runnable() {
              @Override
              public void run() {
                try {
                  okayToRun.await();
                } catch (InterruptedException e) {
                  Thread.currentThread().interrupt();
                  throw new RuntimeException(e);
                }
                runCalled.getAndIncrement();
              }
            },
            directExecutor());
        Runnable execute =
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri Oct 18 22:10:29 UTC 2024
    - 4.7K bytes
    - Viewed (0)
  5. src/main/java/org/codelibs/fess/app/service/FailureUrlService.java

            failureUrl.setErrorName(errorName);
            failureUrl.setErrorLog(getStackTrace(e));
            failureUrl.setLastAccessTime(ComponentUtil.getSystemHelper().getCurrentTimeAsLong());
            failureUrl.setThreadName(Thread.currentThread().getName());
    
            bhv.insertOrUpdate(failureUrl, op -> {
                op.setRefreshPolicy(Constants.TRUE);
            });
            return failureUrl;
        }
    
    Registered: Thu Oct 31 13:40:30 UTC 2024
    - Last Modified: Mon Jun 24 01:20:42 UTC 2024
    - 6.3K bytes
    - Viewed (0)
  6. src/main/java/org/codelibs/fess/helper/ProtocolHelper.java

        protected void loadProtocols(final String basePackage) {
            final List<String> subPackages = new ArrayList<>();
            final String path = basePackage.replace('.', '/');
            final ClassLoader classLoader = Thread.currentThread().getContextClassLoader();
            try {
                final Enumeration<URL> resources = classLoader.getResources(path);
    
                while (resources.hasMoreElements()) {
    Registered: Thu Oct 31 13:40:30 UTC 2024
    - Last Modified: Wed Jun 19 01:34:15 UTC 2024
    - 7.4K bytes
    - Viewed (0)
  7. compat/maven-compat/src/test/java/org/apache/maven/project/AbstractMavenProjectTestCase.java

        }
    
        protected static File getFileForClasspathResource(String resource)
                throws FileNotFoundException, URISyntaxException {
            ClassLoader cloader = Thread.currentThread().getContextClassLoader();
    
            URL resourceUrl = cloader.getResource(resource);
    
            if (resourceUrl == null) {
                throw new FileNotFoundException("Unable to find: " + resource);
            }
    
    Registered: Sun Nov 03 03:35:11 UTC 2024
    - Last Modified: Fri Oct 25 12:31:46 UTC 2024
    - 6.9K bytes
    - Viewed (0)
  8. impl/maven-cli/src/main/java/org/apache/maven/cling/invoker/LookupInvoker.java

            Properties oldProps = (Properties) System.getProperties().clone();
            ClassLoader oldCL = Thread.currentThread().getContextClassLoader();
            try (C context = createContext(invokerRequest)) {
                try {
                    if (context.currentThreadContextClassLoader != null) {
                        Thread.currentThread().setContextClassLoader(context.currentThreadContextClassLoader);
                    }
    Registered: Sun Nov 03 03:35:11 UTC 2024
    - Last Modified: Fri Oct 25 12:31:46 UTC 2024
    - 38K bytes
    - Viewed (0)
  9. impl/maven-cli/src/main/java/org/apache/maven/cling/invoker/mvnenc/DefaultEncryptInvoker.java

                context.addInHeader("This tool is part of Apache Maven 4 distribution.");
                context.addInHeader("");
    
                Thread executeThread = Thread.currentThread();
                context.terminal.handle(Terminal.Signal.INT, signal -> executeThread.interrupt());
                ConsolePrompt.UiConfig config;
                if (context.terminal.getType().equals(Terminal.TYPE_DUMB)
    Registered: Sun Nov 03 03:35:11 UTC 2024
    - Last Modified: Fri Oct 25 12:31:46 UTC 2024
    - 7.6K bytes
    - Viewed (0)
  10. src/main/java/org/codelibs/fess/suggest/index/SuggestIndexer.java

                try {
                    QueryLog queryLog = queryLogReader.read();
                    while (queryLog != null) {
                        if (Thread.currentThread().isInterrupted()) {
                            break;
                        }
                        queryLogs.add(queryLog);
                        queryLog = queryLogReader.read();
    Registered: Fri Nov 08 09:08:12 UTC 2024
    - Last Modified: Sat Oct 12 00:10:39 UTC 2024
    - 26.1K bytes
    - Viewed (0)
Back to top