Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 1 - 10 of 48 for Spin (0.02 seconds)

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

        if (localValue != null & notInstanceOfDelegatingToFuture(localValue)) {
          return getDoneValue(localValue);
        }
        // we delay calling nanoTime until we know we will need to either park or spin
        long endNanos = remainingNanos > 0 ? System.nanoTime() + remainingNanos : 0;
        long_wait_loop:
        if (remainingNanos >= SPIN_THRESHOLD_NANOS) {
          Waiter oldHead = waitersField;
    Created: Fri Dec 26 12:43:10 GMT 2025
    - Last Modified: Thu Aug 07 16:05:33 GMT 2025
    - 33.2K bytes
    - Click Count (0)
  2. android/guava-tests/test/com/google/common/util/concurrent/InterruptibleTaskTest.java

          super.begin();
        }
      }
    
      /**
       * Because Thread.interrupt() can invoke arbitrary code, it can be slow (e.g. perform IO). To
       * protect ourselves from that we want to make sure that tasks don't spin too much waiting for the
       * interrupting thread to complete the protocol.
       */
      /*
       * This test hangs (or maybe is just *very* slow) under Android.
       *
    Created: Fri Dec 26 12:43:10 GMT 2025
    - Last Modified: Tue May 13 18:46:00 GMT 2025
    - 7.1K bytes
    - Click Count (0)
  3. guava/src/com/google/common/util/concurrent/AbstractFutureState.java

        if (localValue != null & notInstanceOfDelegatingToFuture(localValue)) {
          return getDoneValue(localValue);
        }
        // we delay calling nanoTime until we know we will need to either park or spin
        long endNanos = remainingNanos > 0 ? System.nanoTime() + remainingNanos : 0;
        long_wait_loop:
        if (remainingNanos >= SPIN_THRESHOLD_NANOS) {
          Waiter oldHead = waitersField;
    Created: Fri Dec 26 12:43:10 GMT 2025
    - Last Modified: Thu Aug 07 16:05:33 GMT 2025
    - 34.8K bytes
    - Click Count (0)
  4. internal/s3select/csv/reader.go

    // Blocks will read this much and find the first following newline.
    // 128KB appears to be a very reasonable default.
    const csvSplitSize = 128 << 10
    
    // startReaders will read the header if needed and spin up a parser
    // and a number of workers based on GOMAXPROCS.
    // If an error is returned no goroutines have been started and r.err will have been set.
    func (r *Reader) startReaders(newReader func(io.Reader) *csv.Reader) error {
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Tue May 27 15:19:03 GMT 2025
    - 8.8K bytes
    - Click Count (0)
  5. android/guava-tests/test/com/google/common/util/concurrent/JSR166TestCase.java

        } catch (Throwable t) {
          threadUnexpectedException(t);
        }
      }
    
      //     /**
      //      * Spin-waits up to LONG_DELAY_MS until flag becomes true.
      //      */
      //     public void await(AtomicBoolean flag) {
      //         await(flag, LONG_DELAY_MS);
      //     }
    
      //     /**
      //      * Spin-waits up to the specified timeout until flag becomes true.
      //      */
    Created: Fri Dec 26 12:43:10 GMT 2025
    - Last Modified: Thu Dec 11 20:07:52 GMT 2025
    - 37.8K bytes
    - Click Count (0)
  6. android/guava/src/com/google/common/util/concurrent/InterruptibleTask.java

         * been intended for something else, so don't clear it.
         */
        boolean restoreInterruptedBit = false;
        int spinCount = 0;
        // Interrupting Cow Says:
        //  ______
        // < Spin >
        //  ------
        //        \   ^__^
        //         \  (oo)\_______
        //            (__)\       )\/\
        //                ||----w |
        //                ||     ||
        Runnable state = get();
    Created: Fri Dec 26 12:43:10 GMT 2025
    - Last Modified: Thu Aug 07 16:05:33 GMT 2025
    - 10K bytes
    - Click Count (0)
  7. internal/s3select/json/preader.go

    // Blocks will read this much and find the first following newline.
    // 128KB appears to be a very reasonable default.
    const jsonSplitSize = 128 << 10
    
    // startReaders will read the header if needed and spin up a parser
    // and a number of workers based on GOMAXPROCS.
    // If an error is returned no goroutines have been started and r.err will have been set.
    func (r *PReader) startReaders() {
    	r.bufferPool.New = func() []byte {
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Tue May 27 15:19:03 GMT 2025
    - 6.5K bytes
    - Click Count (0)
  8. okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/connection/RealConnectionPool.kt

       * simultaneously adopted and removed.
       */
      private val connections = ConcurrentLinkedQueue<RealConnection>()
    
      init {
        // Put a floor on the keep alive duration, otherwise cleanup will spin loop.
        require(keepAliveDuration > 0L) { "keepAliveDuration <= 0: $keepAliveDuration" }
      }
    
      fun idleConnectionCount(): Int =
        connections.count {
          it.withLock { it.calls.isEmpty() }
        }
    
    Created: Fri Dec 26 11:42:13 GMT 2025
    - Last Modified: Wed Oct 08 03:50:05 GMT 2025
    - 11.1K bytes
    - Click Count (0)
  9. src/main/webapp/js/admin/adminlte.min.js

    [data-card-widget="card-refresh"]',d={source:"",sourceSelector:"",params:{},trigger:r,content:".card-body",loadInContent:!0,loadOnInit:!0,loadErrorTemplate:!0,responseType:"",overlayTemplate:'<div class="overlay"><i class="fas fa-2x fa-sync-alt fa-spin"></i></div>',errorTemplate:'<span class="text-danger"></span>',onLoadStart:function(){},onLoadDone:function(e){return e},onLoadFail:function(e,t,a){}},f=function(){function e(e,t){if(this._element=e,this._parent=e.parents(".card").first(),this._se...
    Created: Sat Dec 20 09:19:18 GMT 2025
    - Last Modified: Sat Oct 26 01:49:09 GMT 2024
    - 45.3K bytes
    - Click Count (0)
  10. src/main/webapp/css/admin/bootstrap.min.css

    margin:0;border:0}legend{display:block;width:100%;max-width:100%;padding:0;margin-bottom:.5rem;font-size:1.5rem;line-height:inherit;color:inherit;white-space:normal}progress{vertical-align:baseline}[type=number]::-webkit-inner-spin-button,[type=number]::-webkit-outer-spin-button{height:auto}[type=search]{outline-offset:-2px;-webkit-appearance:none}[type=search]::-webkit-search-decoration{-webkit-appearance:none}::-webkit-file-upload-button{font:inherit;-webkit-appearance:button}output{display:in...
    Created: Sat Dec 20 09:19:18 GMT 2025
    - Last Modified: Sat Oct 26 01:49:09 GMT 2024
    - 158.5K bytes
    - Click Count (0)
Back to Top