Search Options

Results per page
Sort
Preferred Languages
Advance

Results 451 - 460 of 740 for Thread (1.99 sec)

  1. 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)
  2. 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)
  3. 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)
  4. 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)
  5. 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)
  6. 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)
  7. impl/maven-core/src/main/java/org/apache/maven/project/DefaultProjectBuildingHelper.java

            ClassLoader projectRealm = project.getClassRealm();
    
            if (projectRealm == null) {
                projectRealm = classRealmManager.getCoreRealm();
            }
    
            Thread.currentThread().setContextClassLoader(projectRealm);
        }
    
        private List<org.eclipse.aether.artifact.Artifact> toAetherArtifacts(final List<Artifact> pluginArtifacts) {
    Registered: Sun Dec 28 03:35:09 UTC 2025
    - Last Modified: Fri Jun 06 14:28:57 UTC 2025
    - 10.8K bytes
    - Viewed (0)
  8. src/main/java/jcifs/util/SecureCredentialStorage.java

     * using AES-GCM encryption with PBKDF2 key derivation.
     *
     * Features:
     * - Encrypts credentials at rest using AES-256-GCM
     * - Uses PBKDF2 for key derivation from master password
     * - Secure wiping of sensitive data
     * - Thread-safe operations
     * - Protection against timing attacks
     */
    public class SecureCredentialStorage implements AutoCloseable, Destroyable {
    
    Registered: Sat Dec 20 13:44:44 UTC 2025
    - Last Modified: Sat Aug 30 05:58:03 UTC 2025
    - 12.7K bytes
    - Viewed (0)
  9. android/guava-testlib/src/com/google/common/util/concurrent/testing/SameThreadScheduledExecutorService.java

    import java.util.concurrent.Future;
    import java.util.concurrent.TimeUnit;
    import java.util.concurrent.TimeoutException;
    
    /**
     * A ScheduledExecutorService that executes all scheduled actions immediately in the calling thread.
     *
     * <p>See {@link TestingExecutors#sameThreadScheduledExecutor()} for a full list of constraints.
     *
     * @author John Sirois
     * @author Zach van Schouwen
     */
    @GwtIncompatible
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Thu Aug 07 16:37:28 UTC 2025
    - 6.5K bytes
    - Viewed (0)
  10. guava-testlib/src/com/google/common/util/concurrent/testing/SameThreadScheduledExecutorService.java

    import java.util.concurrent.Future;
    import java.util.concurrent.TimeUnit;
    import java.util.concurrent.TimeoutException;
    
    /**
     * A ScheduledExecutorService that executes all scheduled actions immediately in the calling thread.
     *
     * <p>See {@link TestingExecutors#sameThreadScheduledExecutor()} for a full list of constraints.
     *
     * @author John Sirois
     * @author Zach van Schouwen
     */
    @GwtIncompatible
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Thu Aug 07 16:37:28 UTC 2025
    - 6.5K bytes
    - Viewed (0)
Back to top