Search Options

Results per page
Sort
Preferred Languages
Advance

Results 451 - 460 of 776 for thread (0.05 sec)

  1. android/guava/src/com/google/common/util/concurrent/TimeoutFuture.java

       *
       * Since these fields are non-final that means that TimeoutFuture is not being 'safely published',
       * thus a motivated caller may be able to expose the reference to another thread that would then
       * call cancel() and be unable to cancel the delegate.
       * There are a number of ways to solve this, none of which are very pretty, and it is currently
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Sun Dec 22 03:38:46 UTC 2024
    - 8K bytes
    - Viewed (0)
  2. android/guava/src/com/google/common/collect/ForwardingNavigableMap.java

     * contract.
     *
     * <p>The {@code standard} methods and the 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
     * @since 12.0
     */
    @GwtIncompatible
    public abstract class ForwardingNavigableMap<K extends @Nullable Object, V extends @Nullable Object>
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Sun Dec 22 03:38:46 UTC 2024
    - 14.1K bytes
    - Viewed (0)
  3. guava/src/com/google/common/collect/ForwardingNavigableMap.java

     * contract.
     *
     * <p>The {@code standard} methods and the 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
     * @since 12.0
     */
    @GwtIncompatible
    public abstract class ForwardingNavigableMap<K extends @Nullable Object, V extends @Nullable Object>
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Sun Dec 22 03:38:46 UTC 2024
    - 14.3K bytes
    - Viewed (0)
  4. 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: Sat Dec 20 13:44:44 UTC 2025
    - Last Modified: Sun Aug 31 08:00:57 UTC 2025
    - 30K bytes
    - Viewed (0)
  5. android/guava/src/com/google/common/cache/CacheBuilder.java

       * accommodate as many threads as will ever concurrently modify the table. Using a significantly
       * higher value than you need can waste space and time, and a significantly lower value can lead
       * to thread contention. But overestimates and underestimates within an order of magnitude do not
       * usually have much noticeable impact. A value of one permits only one thread to modify the cache
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Wed Oct 08 18:55:33 UTC 2025
    - 51.9K bytes
    - Viewed (0)
  6. android/guava/src/com/google/common/collect/Tables.java

       * longer, since an iteration across all row keys occurs.
       *
       * <p>Note that this implementation is not synchronized. If multiple threads access this table
       * concurrently and one of the threads modifies the table, it must be synchronized externally.
       *
       * <p>The table is serializable if {@code backingMap}, {@code factory}, the maps generated by
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Mon Sep 22 18:35:44 UTC 2025
    - 24.9K bytes
    - Viewed (0)
  7. fess-crawler/src/main/java/org/codelibs/fess/crawler/service/impl/UrlQueueServiceImpl.java

     *   <li>Checking if a URL has already been visited.</li>
     *   <li>Generating URL queues from a previous session's access results.</li>
     * </ul>
     *
     * <p>
     * The class uses synchronization to ensure thread safety when accessing and modifying the URL queue.
     * It also checks for duplicate URLs before adding them to the queue,
     * both within the queue itself and against previously accessed URLs stored in the {@link MemoryDataHelper}.
    Registered: Sat Dec 20 11:21:39 UTC 2025
    - Last Modified: Sun Jul 06 02:13:03 UTC 2025
    - 9.3K bytes
    - Viewed (0)
  8. 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: Sat Dec 20 09:19:18 UTC 2025
    - Last Modified: Thu Jul 17 08:28:31 UTC 2025
    - 9.2K bytes
    - Viewed (0)
  9. guava-tests/test/com/google/common/base/FinalizableReferenceQueueClassLoaderUnloadingTest.java

        Class<?> sepFrqC = sepLoader.loadClass(frqC.getName());
        assertThat(frqC).isNotSameInstanceAs(sepFrqC);
        // Check the assumptions above.
    
        // FRQ tries to load the Finalizer class (for the reference-collecting thread) in a few ways.
        // If the class is accessible to the system ClassLoader (ClassLoader.getSystemClassLoader())
        // then FRQ does not bother to load Finalizer.class through a separate ClassLoader. That happens
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Tue May 13 18:46:00 UTC 2025
    - 7.6K bytes
    - Viewed (0)
  10. guava/src/com/google/common/util/concurrent/ListenerCallQueue.java

          }
        }
      }
    
      /**
       * Dispatches all events enqueued prior to this call, serially and in order, for every listener.
       *
       * <p>Note: this method is idempotent and safe to call from any thread
       */
      public void dispatch() {
        // iterate by index to avoid concurrent modification exceptions
        for (int i = 0; i < listeners.size(); i++) {
          listeners.get(i).dispatch();
        }
      }
    
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Tue May 13 17:27:14 UTC 2025
    - 8.1K bytes
    - Viewed (0)
Back to top