Search Options

Results per page
Sort
Preferred Languages
Advance

Results 431 - 440 of 583 for threadId (0.13 sec)

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

     * full queue, the queue automatically removes its head element. This is different from conventional
     * bounded queues, which either block or reject new elements when full.
     *
     * <p>This class is not thread-safe, and does not accept null elements.
     *
     * @author Kurt Alfred Kluever
     * @since 15.0
     */
    @GwtCompatible
    public final class EvictingQueue<E> extends ForwardingQueue<E> implements Serializable {
    
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Thu Feb 13 17:34:21 UTC 2025
    - 4.6K bytes
    - Viewed (0)
  2. guava/src/com/google/common/escape/Escaper.java

     * string {@code "Foo<Bar>"}.
     *
     * <p>An {@code Escaper} instance is required to be stateless, and safe when used concurrently by
     * multiple threads.
     *
     * <p>Because, in general, escaping operates on the code points of a string and not on its
     * individual {@code char} values, it is not safe to assume that {@code escape(s)} is equivalent to
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Thu Feb 13 15:45:16 UTC 2025
    - 4.7K bytes
    - Viewed (0)
  3. 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: Sun Sep 07 00:10:21 UTC 2025
    - Last Modified: Sat Aug 30 05:58:03 UTC 2025
    - 12.7K 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: Sun Sep 07 00:10:21 UTC 2025
    - Last Modified: Sun Aug 31 08:00:57 UTC 2025
    - 30K bytes
    - Viewed (0)
  5. api/maven-api-core/src/main/java/org/apache/maven/api/services/Request.java

     * </ul>
     *
     * <p>This interface is designed to be extended by specific request types that handle
     * different Maven operations. All implementations must be immutable to ensure thread safety
     * and predictable behavior in concurrent environments.
     *
     * @param <S> the type of ProtoSession associated with this request, allowing for
     *           type-safe session handling in specific request implementations
    Registered: Sun Sep 07 03:35:12 UTC 2025
    - Last Modified: Fri Feb 07 00:45:02 UTC 2025
    - 4K bytes
    - Viewed (0)
  6. android/guava-testlib/test/com/google/common/testing/FakeTickerTest.java

            new Callable<@Nullable Void>() {
              @Override
              public @Nullable Void call() throws Exception {
                // adds two nanoseconds to the ticker
                ticker.advance(1L);
                Thread.sleep(10);
                ticker.advance(1L);
                return null;
              }
            });
    
        assertEquals(numberOfThreads * 2, ticker.read());
      }
    
      @GwtIncompatible // concurrency
    
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Thu Aug 07 16:05:33 UTC 2025
    - 6.5K bytes
    - Viewed (0)
  7. src/main/java/jcifs/SmbResourceException.java

            case BUFFER:
                return "Reduce buffer usage or increase buffer pool size";
            case THREAD_POOL:
                return "Reduce concurrent operations or increase thread pool size";
            default:
                return "Check resource availability and retry";
            }
        }
    
        /**
         * Static factory for file handle exhaustion
         */
    Registered: Sun Sep 07 00:10:21 UTC 2025
    - Last Modified: Sat Aug 30 05:58:03 UTC 2025
    - 5.6K bytes
    - Viewed (0)
  8. android/guava/src/com/google/common/collect/MapMakerInternalMap.java

         * cleaning up from the read thread.
         */
        void postReadCleanup() {
          if ((readCount.incrementAndGet() & DRAIN_THRESHOLD) == 0) {
            runCleanup();
          }
        }
    
        /**
         * Performs routine cleanup prior to executing a write. This should be called every time a write
         * thread acquires the segment lock, immediately after acquiring the lock.
         */
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Mon Aug 11 19:31:30 UTC 2025
    - 90K bytes
    - Viewed (0)
  9. guava/src/com/google/common/collect/Platform.java

      static <E extends @Nullable Object> Set<E> newHashSetWithExpectedSize(int expectedSize) {
        return Sets.newHashSetWithExpectedSize(expectedSize);
      }
    
      /** Returns the platform preferred implementation of a thread-safe hash set. */
      static <E> Set<E> newConcurrentHashSet() {
        return ConcurrentHashMap.newKeySet();
      }
    
      /**
       * Returns the platform preferred implementation of an insertion ordered set based on a hash
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Thu Aug 07 16:05:33 UTC 2025
    - 5.5K bytes
    - Viewed (0)
  10. compat/maven-compat/src/main/java/org/apache/maven/artifact/repository/metadata/AbstractRepositoryMetadata.java

            if (metadataFile.length() == 0) {
                if (!metadataFile.delete()) {
                    // sleep for 10ms just in case this is windows holding a file lock
                    try {
                        Thread.sleep(10);
                    } catch (InterruptedException e) {
                        // ignore
                    }
                    metadataFile.delete(); // if this fails, forget about it, we'll try to overwrite it anyway so no need
    Registered: Sun Sep 07 03:35:12 UTC 2025
    - Last Modified: Fri Jun 06 14:28:57 UTC 2025
    - 7.2K bytes
    - Viewed (0)
Back to top