Search Options

Results per page
Sort
Preferred Languages
Advance

Results 71 - 80 of 109 for currentThread (0.11 sec)

  1. android/guava-tests/test/com/google/common/util/concurrent/InterruptibleTaskTest.java

                  new CountDownLatch(1).await(); // the interrupt will wake us up
                } catch (InterruptedException ie) {
                  // continue
                }
                LockSupport.unpark(Thread.currentThread()); // simulate a spurious wakeup.
                return null;
              }
    
              @Override
              boolean isDone() {
                return false;
              }
    
              @Override
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri Oct 18 22:10:29 UTC 2024
    - 6.6K bytes
    - Viewed (0)
  2. src/main/java/org/codelibs/core/io/ResourceUtil.java

        }
    
        /**
         * コンテキストクラスローダを返します。
         *
         * @return コンテキストクラスローダ
         */
        public static ClassLoader getClassLoader() {
            return Thread.currentThread().getContextClassLoader();
        }
    
        /**
         * コンテキストクラスローダからリソースを返します。
         *
         * @param path
         *            リソースのパス。{@literal null}や空文字列であってはいけません
         * @return リソースの{@link URL}
    Registered: Fri Nov 01 20:58:10 UTC 2024
    - Last Modified: Thu Mar 07 01:59:08 UTC 2024
    - 15.8K bytes
    - Viewed (0)
  3. fess-crawler/src/main/java/org/codelibs/fess/crawler/extractor/impl/HtmlXpathExtractor.java

            } catch (final Exception e) {
                throw new ExtractException(e);
            }
        }
    
        protected XPathAPI getXPathAPI() {
            try {
                return xpathAPICache.get(Thread.currentThread().getName());
            } catch (final ExecutionException e) {
                if (logger.isDebugEnabled()) {
                    logger.debug("Failed to retrieval a cache.", e);
                }
                return new XPathAPI();
    Registered: Sun Nov 10 03:50:12 UTC 2024
    - Last Modified: Thu Feb 22 01:47:32 UTC 2024
    - 7K bytes
    - Viewed (0)
  4. fess-crawler/src/main/java/org/codelibs/fess/crawler/extractor/impl/ApiExtractor.java

            // start
            AccessTimeoutTarget accessTimeoutTarget = null;
            TimeoutTask accessTimeoutTask = null;
            if (accessTimeout != null) {
                accessTimeoutTarget = new AccessTimeoutTarget(Thread.currentThread());
                accessTimeoutTask = TimeoutManager.getInstance().addTimeoutTarget(accessTimeoutTarget, accessTimeout, false);
            }
    
            final ExtractData data = new ExtractData();
    Registered: Sun Nov 10 03:50:12 UTC 2024
    - Last Modified: Thu Feb 22 01:47:32 UTC 2024
    - 10K bytes
    - Viewed (0)
  5. src/main/java/jcifs/smb/SmbTreeImpl.java

                log.trace("Acquire tree " + usage + " " + this);
            }
    
            if ( track && this.traceResource ) {
                synchronized ( this.acquires ) {
                    this.acquires.add(truncateTrace(Thread.currentThread().getStackTrace()));
                }
            }
    
            if ( usage == 1 ) {
                synchronized ( this ) {
                    if ( this.sessionAcquired.compareAndSet(false, true) ) {
    Registered: Sun Nov 03 00:10:13 UTC 2024
    - Last Modified: Thu Jan 05 13:06:39 UTC 2023
    - 29.6K bytes
    - Viewed (0)
  6. guava/src/com/google/common/io/Resources.java

      // e.g. Optional<URL> tryGetResource or boolean resourceExists
      public static URL getResource(String resourceName) {
        ClassLoader loader =
            MoreObjects.firstNonNull(
                Thread.currentThread().getContextClassLoader(), Resources.class.getClassLoader());
        URL url = loader.getResource(resourceName);
        checkArgument(url != null, "resource %s not found.", resourceName);
        return url;
      }
    
      /**
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri Aug 02 13:50:22 UTC 2024
    - 7.5K bytes
    - Viewed (0)
  7. fess-crawler/src/main/java/org/codelibs/fess/crawler/client/fs/FileSystemClient.java

            // start
            AccessTimeoutTarget accessTimeoutTarget = null;
            TimeoutTask accessTimeoutTask = null;
            if (accessTimeout != null) {
                accessTimeoutTarget = new AccessTimeoutTarget(Thread.currentThread());
                accessTimeoutTask = TimeoutManager.getInstance().addTimeoutTarget(accessTimeoutTarget, accessTimeout, false);
            }
    
            try {
                return getResponseData(uri, includeContent);
    Registered: Sun Nov 10 03:50:12 UTC 2024
    - Last Modified: Thu Feb 22 01:47:32 UTC 2024
    - 11.8K bytes
    - Viewed (0)
  8. src/main/java/org/codelibs/fess/helper/ActivityHelper.java

            buf.append(",\"event.dataset\":\"").append(ecsEventDataset).append('"');
            buf.append(",\"process.thread.name\":\"").append(StringEscapeUtils.escapeJson(Thread.currentThread().getName())).append('"');
            buf.append(",\"log.logger\":\"").append(StringEscapeUtils.escapeJson(this.getClass().getName())).append('"');
    Registered: Thu Oct 31 13:40:30 UTC 2024
    - Last Modified: Thu Feb 22 01:53:18 UTC 2024
    - 7.7K bytes
    - Viewed (0)
  9. fess-crawler/src/main/java/org/codelibs/fess/crawler/extractor/impl/PdfExtractor.java

                    } catch (final Exception e) {
                        exceptionSet.add(e);
                    } finally {
                        done.set(true);
                    }
                }, Thread.currentThread().getName() + "-pdf");
                task.setDaemon(isDaemonThread);
                task.start();
                task.join(timeout);
                if (!done.get()) {
                    for (int i = 0; i < 100 && !done.get(); i++) {
    Registered: Sun Nov 10 03:50:12 UTC 2024
    - Last Modified: Thu Feb 22 01:36:27 UTC 2024
    - 9.8K bytes
    - Viewed (0)
  10. android/guava/src/com/google/common/util/concurrent/SequentialExecutor.java

            // is returned to the delegate Executor interrupted so that it may handle the
            // interruption if it likes.
            if (interruptedDuringTask) {
              Thread.currentThread().interrupt();
            }
          }
        }
    
        @SuppressWarnings("GuardedBy")
        @Override
        public String toString() {
          Runnable currentlyRunning = task;
          if (currentlyRunning != null) {
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Thu Feb 01 21:46:34 UTC 2024
    - 10.6K bytes
    - Viewed (0)
Back to top