Search Options

Results per page
Sort
Preferred Languages
Advance

Results 311 - 320 of 711 for thread (0.04 sec)

  1. android/guava/src/com/google/common/collect/ForwardingMultiset.java

     * invoke methods, they invoke methods on the {@code ForwardingMultiset}.
     *
     * <p>The {@code standard} methods and any collection views they return are not guaranteed to be
     * thread-safe, even when all of the methods that they depend on are thread-safe.
     *
     * @author Kevin Bourrillion
     * @author Louis Wasserman
     * @since 2.0
     */
    @GwtCompatible
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Tue Jul 08 18:32:10 UTC 2025
    - 10.3K bytes
    - Viewed (0)
  2. src/main/java/org/codelibs/fess/ingest/IngestFactory.java

            // Default constructor
        }
    
        /**
         * Adds an ingester to the factory.
         * The ingester is inserted into the collection and the array is re-sorted by priority.
         * This method is thread-safe.
         *
         * @param ingester the ingester to add
         */
        public synchronized void add(final Ingester ingester) {
            if (logger.isDebugEnabled()) {
    Registered: Thu Sep 04 12:52:25 UTC 2025
    - Last Modified: Thu Jul 17 08:28:31 UTC 2025
    - 2.4K bytes
    - Viewed (0)
  3. src/main/java/org/codelibs/fess/helper/AbstractConfigHelper.java

    /**
     * The abstract helper for configuration.
     *
     * This class provides a basic framework for managing configurations that can be reloaded.
     * It includes functionality for updating configurations in a separate thread and controlling the reloading interval.
     */
    public abstract class AbstractConfigHelper {
    
        /**
         * Default constructor.
         */
        public AbstractConfigHelper() {
            // Default constructor
        }
    Registered: Thu Sep 04 12:52:25 UTC 2025
    - Last Modified: Thu Jul 17 08:28:31 UTC 2025
    - 1.9K bytes
    - Viewed (0)
  4. src/main/java/org/codelibs/fess/thumbnail/ThumbnailManager.java

         * Stops background processing and waits for threads to complete.
         */
        @PreDestroy
        public void destroy() {
            generating = false;
            thumbnailQueueThread.interrupt();
            try {
                thumbnailQueueThread.join(10000);
            } catch (final InterruptedException e) {
                logger.warn("Thumbnail thread is timeouted.", e);
            }
            generatorList.forEach(g -> {
    Registered: Thu Sep 04 12:52:25 UTC 2025
    - Last Modified: Tue Aug 19 14:09:36 UTC 2025
    - 26.9K bytes
    - Viewed (0)
  5. api/maven-api-cli/src/main/java/org/apache/maven/api/cli/mvn/MavenOptions.java

        @Nonnull
        Optional<Boolean> alsoMakeDependents();
    
        /**
         * Returns the number of threads used for parallel builds.
         *
         * @return an {@link Optional} containing the number of threads (or "1C" for one thread per CPU core), or empty if not specified
         */
        @Nonnull
        Optional<String> threads();
    
        /**
         * Returns the id of the build strategy to use.
         *
    Registered: Sun Sep 07 03:35:12 UTC 2025
    - Last Modified: Wed Jun 11 13:14:09 UTC 2025
    - 8K bytes
    - Viewed (0)
  6. src/test/java/org/codelibs/fess/job/ExecJobTest.java

            CountDownLatch latch = new CountDownLatch(2);
    
            Thread t1 = new Thread(() -> {
                for (int i = 0; i < 100; i++) {
                    execJob.jvmOptions("-Xmx" + i + "m");
                }
                latch.countDown();
            });
    
            Thread t2 = new Thread(() -> {
                for (int i = 0; i < 100; i++) {
                    execJob.jvmOptions("-Xms" + i + "m");
    Registered: Thu Sep 04 12:52:25 UTC 2025
    - Last Modified: Tue Aug 19 14:09:36 UTC 2025
    - 24.5K bytes
    - Viewed (0)
  7. src/test/java/org/codelibs/fess/unit/TestSystemProperties.java

                return null;
            }
        }
    
        private void loadTestProperties() {
            // Load system.properties from test classpath
            try (InputStream is = Thread.currentThread().getContextClassLoader().getResourceAsStream("system.properties")) {
                if (is != null) {
                    Properties props = new Properties();
                    props.load(is);
    Registered: Thu Sep 04 12:52:25 UTC 2025
    - Last Modified: Tue Aug 19 14:09:36 UTC 2025
    - 2.5K bytes
    - Viewed (0)
  8. guava-gwt/src-super/com/google/common/collect/super/com/google/common/collect/ForwardingSortedMultiset.java

     * method.
     *
     * <p>The {@code standard} methods and any collection views they return are not guaranteed to be
     * thread-safe, even when all of the methods that they depend on are thread-safe.
     *
     * @author Louis Wasserman
     */
    public abstract class ForwardingSortedMultiset<E extends @Nullable Object>
        extends ForwardingMultiset<E> implements SortedMultiset<E> {
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Sun Dec 22 03:38:46 UTC 2024
    - 8K bytes
    - Viewed (0)
  9. src/main/java/org/codelibs/fess/exec/SuggestCreator.java

                SingletonLaContainerFactory.setExternalContextComponentDefRegister(new GenericExternalContextComponentDefRegister());
                SingletonLaContainerFactory.init();
    
                final Thread shutdownCallback = new Thread("ShutdownHook") {
                    @Override
                    public void run() {
                        if (logger.isDebugEnabled()) {
                            logger.debug("Destroying LaContainer..");
    Registered: Thu Sep 04 12:52:25 UTC 2025
    - Last Modified: Thu Aug 07 03:06:29 UTC 2025
    - 11K bytes
    - Viewed (0)
  10. okhttp-testing-support/src/main/kotlin/okhttp3/RecordingEventListener.kt

      private val forbiddenLocks = mutableListOf<Any>()
    
      /** The timestamp of the last taken event, used to measure elapsed time between events. */
      private var lastTimestampNs: Long? = null
    
      /** Confirm that the thread does not hold a lock on `lock` during the callback. */
      fun forbidLock(lock: Any) {
        forbiddenLocks.add(lock)
      }
    
      /**
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Tue May 27 14:58:02 UTC 2025
    - 9.5K bytes
    - Viewed (0)
Back to top