Search Options

Results per page
Sort
Preferred Languages
Advance

Results 161 - 170 of 331 for enqueue (0.54 sec)

  1. fess-crawler/src/main/java/org/codelibs/fess/crawler/entity/UrlQueueImpl.java

        /** The metadata associated with the URL queue. */
        protected String metaData;
    
        /** The encoding of the URL queue. */
        protected String encoding;
    
        /** The parent URL of the current URL in the queue. */
        protected String parentUrl;
    
        /** The depth of the URL in the queue. */
        protected Integer depth;
    
        /** The last modified timestamp of the URL in the queue. */
        protected Long lastModified;
    
    Registered: Sat Dec 20 11:21:39 UTC 2025
    - Last Modified: Sun Jul 06 02:13:03 UTC 2025
    - 6.1K bytes
    - Viewed (0)
  2. src/main/webapp/js/admin/adminlte.min.js

    er"+Ne)===$e?this._options.noTransitionAfterReload?e.addClass("hold-transition").addClass($e).delay(50).queue((function(){n.default(this).removeClass("hold-transition"),n.default(this).dequeue()})):e.addClass($e):this._options.noTransitionAfterReload?e.addClass("hold-transition").removeClass($e).delay(50).queue((function(){n.default(this).removeClass("hold-transition"),n.default(this).dequeue()})):e.removeClass($e)}},t._init=function(){var e=this;this.remember(),this.autoCollapse(),n.default(win...
    Registered: Sat Dec 20 09:19:18 UTC 2025
    - Last Modified: Sat Oct 26 01:49:09 UTC 2024
    - 45.3K bytes
    - Viewed (0)
  3. build-logic/documentation/src/main/groovy/gradlebuild/docs/dsl/source/model/MethodMetaData.java

        public MethodMetaData getOverriddenMethod() {
            LinkedList<ClassMetaData> queue = new LinkedList<ClassMetaData>();
            queue.add(ownerClass.getSuperClass());
            queue.addAll(ownerClass.getInterfaces());
    
            String overrideSignature = getOverrideSignature();
    
            while (!queue.isEmpty()) {
                ClassMetaData cl = queue.removeFirst();
                if (cl == null) {
                    continue;
                }
    Registered: Wed Dec 31 11:36:14 UTC 2025
    - Last Modified: Wed Dec 09 08:14:05 UTC 2020
    - 4.9K bytes
    - Viewed (0)
  4. src/main/java/org/codelibs/core/crypto/CachedCipher.java

         */
        protected String charsetName = CoreLibConstants.UTF_8;
    
        /**
         * The queue of ciphers for encryption.
         */
        protected Queue<Cipher> encryptoQueue = new ConcurrentLinkedQueue<>();
    
        /**
         * The queue of ciphers for decryption.
         */
        protected Queue<Cipher> decryptoQueue = new ConcurrentLinkedQueue<>();
    
        /**
         * Encrypts the given data.
         *
    Registered: Sat Dec 20 08:55:33 UTC 2025
    - Last Modified: Sat Nov 22 11:21:59 UTC 2025
    - 15.9K bytes
    - Viewed (0)
  5. android/guava-tests/test/com/google/common/collect/SynchronizedQueueTest.java

        Queue<String> outer = Synchronized.queue(inner, inner.mutex);
        outer.add("foo"); // necessary because we try to remove elements later on
        return outer;
      }
    
      private static final class TestQueue<E> implements Queue<E> {
        private final Queue<E> delegate = new LinkedList<>();
        private final Object mutex = new Object[0]; // something Serializable
    
        @Override
        public boolean offer(E o) {
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Wed Jul 16 17:42:14 UTC 2025
    - 4.8K bytes
    - Viewed (0)
  6. android/guava/src/com/google/common/base/internal/Finalizer.java

          ReferenceQueue<Object> queue,
          PhantomReference<Object> frqReference) {
        this.queue = queue;
    
        this.finalizableReferenceClassReference = new WeakReference<>(finalizableReferenceClass);
    
        // Keep track of the FRQ that started us so we know when to stop.
        this.frqReference = frqReference;
      }
    
      /** Loops continuously, pulling references off the queue and cleaning them up. */
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Sun Dec 22 03:38:46 UTC 2024
    - 9.3K bytes
    - Viewed (0)
  7. android/guava/src/com/google/common/base/FinalizablePhantomReference.java

      /**
       * Constructs a new finalizable phantom reference.
       *
       * @param referent to phantom reference
       * @param queue that should finalize the referent
       */
      protected FinalizablePhantomReference(@Nullable T referent, FinalizableReferenceQueue queue) {
        super(referent, queue.queue);
        queue.cleanUp();
      }
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Sun Dec 22 03:38:46 UTC 2024
    - 1.6K bytes
    - Viewed (0)
  8. src/main/webapp/js/admin/adminlte.min.js.map

    (this._config.controlsidebarSlide) {\n      $html.addClass(CLASS_NAME_CONTROL_SIDEBAR_ANIMATE)\n      $(this._config.target).show().delay(10).queue(function () {\n        $body.addClass(CLASS_NAME_CONTROL_SIDEBAR_SLIDE).delay(300).queue(function () {\n          $html.removeClass(CLASS_NAME_CONTROL_SIDEBAR_ANIMATE)\n          $(this).dequeue()\n        })\n        $(this).dequeue()\n      })\n    } else {\n      $body.addClass(CLASS_NAME_CONTROL_SIDEBAR_OPEN)\n    }\n\n    this._fixHeight()\n    this._fixScrollHeight()\n\n...
    Registered: Sat Dec 20 09:19:18 UTC 2025
    - Last Modified: Sat Oct 26 01:49:09 UTC 2024
    - 132.4K bytes
    - Viewed (0)
  9. android/guava/src/com/google/common/collect/ForwardingQueue.java

    import com.google.errorprone.annotations.CanIgnoreReturnValue;
    import java.util.NoSuchElementException;
    import java.util.Queue;
    import org.jspecify.annotations.Nullable;
    
    /**
     * A queue which forwards all its method calls to another queue. Subclasses should override one or
     * more methods to modify the behavior of the backing queue as desired per the <a
     * href="http://en.wikipedia.org/wiki/Decorator_pattern">decorator pattern</a>.
     *
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Sun Dec 22 03:38:46 UTC 2024
    - 3.9K bytes
    - Viewed (0)
  10. internal/s3select/csv/reader.go

    	if !utf8.Valid(next) {
    		return errInvalidTextEncodingError()
    	}
    
    	// Create queue
    	r.queue = make(chan *queueItem, runtime.GOMAXPROCS(0))
    	r.input = make(chan *queueItem, runtime.GOMAXPROCS(0))
    	r.readerWg.Add(1)
    
    	// Start splitter
    	go func() {
    		defer close(r.input)
    		defer close(r.queue)
    		defer r.readerWg.Done()
    		for {
    			q := queueItem{
    				input: next,
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Tue May 27 15:19:03 UTC 2025
    - 8.8K bytes
    - Viewed (0)
Back to top