Search Options

Results per page
Sort
Preferred Languages
Advance

Results 21 - 30 of 251 for holding (0.05 sec)

  1. guava/src/com/google/common/util/concurrent/AbstractExecutionThreadService.java

      protected void shutDown() throws Exception {}
    
      /**
       * Invoked to request the service to stop.
       *
       * <p>By default this method does nothing.
       *
       * <p>Currently, this method is invoked while holding a lock. If an implementation of this method
       * blocks, it can prevent this service from changing state. If you need to performing a blocking
       * operation in order to trigger shutdown, consider instead registering a listener and
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Fri Jul 11 18:52:30 UTC 2025
    - 7.5K bytes
    - Viewed (0)
  2. okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/http2/Http2Stream.kt

          assertLockNotHeld()
    
          connection.updateConnectionFlowControl(read)
        }
    
        /**
         * Accept bytes on the connection's reader thread. This function avoids holding locks while it
         * performs blocking reads for the incoming bytes.
         */
        @Throws(IOException::class)
        internal fun receive(
          source: BufferedSource,
          byteCount: Long,
        ) {
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Mon Jul 07 18:57:05 UTC 2025
    - 22.4K bytes
    - Viewed (0)
  3. internal/lru/lru.go

    	ttl  time.Duration
    	done chan struct{}
    
    	// buckets for expiration
    	buckets []bucket[K, V]
    	// uint8 because it's number between 0 and numBuckets
    	nextCleanupBucket uint8
    }
    
    // bucket is a container for holding entries to be expired
    type bucket[K comparable, V any] struct {
    	entries     map[K]*Entry[K, V]
    	newestEntry time.Time
    }
    
    // noEvictionTTL - very long ttl to prevent eviction
    Registered: Sun Sep 07 09:35:13 UTC 2025
    - Last Modified: Fri Apr 25 08:22:26 UTC 2025
    - 12.5K bytes
    - Viewed (0)
  4. guava/src/com/google/common/util/concurrent/Striped.java

     * itself is reclaimable. <i>Weak</i> means that locks/semaphores are created lazily, and they are
     * allowed to be reclaimed if nobody is holding on to them. This is useful, for example, if one
     * wants to create a {@code Striped<Lock>} of many locks, but worries that in most cases only a
     * small portion of these would be in use.
     *
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Sat Aug 09 01:14:59 UTC 2025
    - 20.6K bytes
    - Viewed (0)
  5. src/main/java/jcifs/SmbConstants.java

     * License along with this library; if not, write to the Free Software
     * Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA  02111-1307  USA
     */
    package jcifs;
    
    /**
     * Utility class holding several protocol constrants
     *
     * @author mbechler
     *
     *
     * <p>This interface is intended for internal use.</p>
     */
    public interface SmbConstants {
    
        /**
    Registered: Sun Sep 07 00:10:21 UTC 2025
    - Last Modified: Sun Aug 24 00:49:49 UTC 2025
    - 12.8K bytes
    - Viewed (0)
  6. misc/cgo/gmp/gmp.go

    Garbage collection is the big problem.  It is fine for the Go world to
    have pointers into the C world and to free those pointers when they
    are no longer needed.  To help, the Go code can define Go objects
    holding the C pointers and use runtime.SetFinalizer on those Go objects.
    
    It is much more difficult for the C world to have pointers into the Go
    world, because the Go garbage collector is unaware of the memory
    Registered: Tue Sep 09 11:13:09 UTC 2025
    - Last Modified: Mon Apr 11 16:34:30 UTC 2022
    - 9.5K bytes
    - Viewed (0)
  7. okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/http2/Http2Connection.kt

    @Suppress("NAME_SHADOWING")
    class Http2Connection internal constructor(
      builder: Builder,
    ) : Closeable,
      Lockable {
      // Internal state of this connection is guarded by 'lock'. No blocking operations may be
      // performed while holding this lock!
      //
      // Socket writes are guarded by frameWriter.
      //
      // Socket reads are unguarded but are only made by the reader thread.
      //
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Thu Jul 31 04:18:40 UTC 2025
    - 31.8K bytes
    - Viewed (0)
  8. okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/connection/RealConnection.kt

    import okio.Buffer
    
    /**
     * A connection to a remote web server capable of carrying 1 or more concurrent streams.
     *
     * Connections are shared in a connection pool. Accesses to the connection's state must be guarded
     * by holding a lock on the connection.
     */
    class RealConnection internal constructor(
      val taskRunner: TaskRunner,
      val connectionPool: RealConnectionPool,
      override val route: Route,
      /** The low-level TCP socket. */
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Thu Jul 31 04:18:40 UTC 2025
    - 14.9K bytes
    - Viewed (0)
  9. guava/src/com/google/common/util/concurrent/AbstractService.java

      }
    
      @Override
      public String toString() {
        return getClass().getSimpleName() + " [" + state() + "]";
      }
    
      /**
       * Attempts to execute all the listeners in {@link #listeners} while not holding the {@link
       * #monitor}.
       */
      private void dispatchListenerEvents() {
        if (!monitor.isOccupiedByCurrentThread()) {
          listeners.dispatch();
        }
      }
    
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Wed Feb 19 21:24:11 UTC 2025
    - 20.7K bytes
    - Viewed (0)
  10. src/builtin/builtin.go

    // new elements. If it does not, a new underlying array will be allocated.
    // Append returns the updated slice. It is therefore necessary to store the
    // result of append, often in the variable holding the slice itself:
    //
    //	slice = append(slice, elem1, elem2)
    //	slice = append(slice, anotherSlice...)
    //
    // As a special case, it is legal to append a string to a byte slice, like this:
    //
    Registered: Tue Sep 09 11:13:09 UTC 2025
    - Last Modified: Mon Dec 30 23:59:23 UTC 2024
    - 12.8K bytes
    - Viewed (0)
Back to top