Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 91 - 100 of 265 for synchronize (0.15 seconds)

The search processing time has exceeded the limit. The displayed results may be partial.

  1. okhttp/src/commonJvmAndroid/kotlin/okhttp3/Cache.kt

          hitCount++
        }
      }
    
      @Synchronized internal fun trackConditionalCacheHit() {
        hitCount++
      }
    
      @Synchronized fun networkCount(): Int = networkCount
    
      @Synchronized fun hitCount(): Int = hitCount
    
      @Synchronized fun requestCount(): Int = requestCount
    
      private inner class RealCacheRequest(
    Created: Fri Apr 03 11:42:14 GMT 2026
    - Last Modified: Fri Mar 20 09:13:37 GMT 2026
    - 26.9K bytes
    - Click Count (0)
  2. src/main/java/jcifs/smb1/smb1/SmbTransport.java

        static LogStream log = LogStream.getInstance();
        static HashMap dfsRoots = null;
    
        static synchronized SmbTransport getSmbTransport(final UniAddress address, final int port) {
            return getSmbTransport(address, port, LADDR, LPORT, null);
        }
    
        static synchronized SmbTransport getSmbTransport(final UniAddress address, final int port, final InetAddress localAddr,
    Created: Sun Apr 05 00:10:12 GMT 2026
    - Last Modified: Sat Aug 16 01:32:48 GMT 2025
    - 31.8K bytes
    - Click Count (0)
  3. docs/fr/docs/async.md

    Vous et votre crush 😍 étant occupés à vérifier que personne ne passe devant vous prendre vos burgers au moment où ils arriveront 🕙, vous ne pouvez pas vous préoccuper de votre crush 😞.
    
    C'est du travail « synchrone », vous être « synchronisés » avec le serveur/cuisinier 👨‍🍳. Vous devez attendre 🕙 et être présent au moment exact où le serveur/cuisinier 👨‍🍳 finira les burgers 🍔 et vous les donnera, sinon quelqu'un risque de vous les prendre.
    
    Created: Sun Apr 05 07:19:11 GMT 2026
    - Last Modified: Thu Mar 19 18:37:13 GMT 2026
    - 27.3K bytes
    - Click Count (0)
  4. android/guava/src/com/google/common/util/concurrent/ExecutionList.java

        // Lock while we check state. We must maintain the lock while adding the new pair so that
        // another thread can't run the list out from under us. We only add to the list if we have not
        // yet started execution.
        synchronized (lock) {
          if (!executed) {
            runnables = new RunnableExecutorPair(runnable, executor, runnables);
            return;
          }
        }
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Tue Feb 10 11:51:21 GMT 2026
    - 6.9K bytes
    - Click Count (0)
  5. android/guava/src/com/google/common/util/concurrent/AbstractFutureState.java

          synchronized (future) {
            if (future.waitersField == expect) {
              future.waitersField = update;
              return true;
            }
            return false;
          }
        }
    
        @Override
        boolean casListeners(
            AbstractFutureState<?> future, @Nullable Listener expect, Listener update) {
          synchronized (future) {
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Thu Aug 07 16:05:33 GMT 2025
    - 33.2K bytes
    - Click Count (0)
  6. src/main/java/jcifs/smb/SmbPipeInputStream.java

         *
         * @return the tree handle implementation
         * @throws CIFSException if a connection error occurs
         */
        protected synchronized SmbTreeHandleImpl ensureTreeConnected() throws CIFSException {
            return this.handle.ensureTreeConnected();
        }
    
        @Override
        protected synchronized SmbFileHandleImpl ensureOpen() throws CIFSException {
            return this.handle.ensureOpen();
        }
    
        /**
    Created: Sun Apr 05 00:10:12 GMT 2026
    - Last Modified: Sat Aug 16 01:32:48 GMT 2025
    - 3.8K bytes
    - Click Count (0)
  7. src/test/java/jcifs/BufferCacheTest.java

                this.cache = new ArrayList<>(maxBuffers);
            }
    
            @Override
            public synchronized byte[] getBuffer() {
                if (!cache.isEmpty()) {
                    return cache.remove(0);
                }
                return new byte[bufferSize];
            }
    
            @Override
            public synchronized void releaseBuffer(byte[] buf) {
                if (buf != null && cache.size() < maxBuffers) {
    Created: Sun Apr 05 00:10:12 GMT 2026
    - Last Modified: Thu Aug 14 05:31:44 GMT 2025
    - 4.3K bytes
    - Click Count (0)
  8. src/main/java/jcifs/smb1/netbios/Lmhosts.java

         *
         * @param host the hostname to resolve
         * @return the resolved NbtAddress or null if not found
         */
    
        public synchronized static NbtAddress getByName(final String host) {
            return getByName(new Name(host, 0x20, null));
        }
    
        synchronized static NbtAddress getByName(final Name name) {
            NbtAddress result = null;
    
            try {
                if (FILENAME != null) {
    Created: Sun Apr 05 00:10:12 GMT 2026
    - Last Modified: Sat Aug 16 01:32:48 GMT 2025
    - 6K bytes
    - Click Count (0)
  9. src/main/java/jcifs/smb1/netbios/NameServiceClient.java

            int max = NbtAddress.NBNS.length;
    
            if (max == 0) {
                max = 1; /* No WINs, try only bcast addr */
            }
    
            synchronized (response) {
                while (max-- > 0) {
                    try {
                        synchronized (LOCK) {
                            request.nameTrnId = getNextNameTrnId();
                            nid = request.nameTrnId;
    
    Created: Sun Apr 05 00:10:12 GMT 2026
    - Last Modified: Thu Aug 14 07:14:38 GMT 2025
    - 17.6K bytes
    - Click Count (0)
  10. android/guava-tests/test/com/google/common/collect/SynchronizedQueueTest.java

    import org.jspecify.annotations.Nullable;
    
    /**
     * Tests for {@link Synchronized#queue} and {@link Queues#synchronizedQueue}.
     *
     * @author Kurt Alfred Kluever
     */
    @NullUnmarked
    public class SynchronizedQueueTest extends TestCase {
    
      protected Queue<String> create() {
        TestQueue<String> inner = new TestQueue<>();
        Queue<String> outer = Synchronized.queue(inner, inner.mutex);
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Wed Jul 16 17:42:14 GMT 2025
    - 4.8K bytes
    - Click Count (0)
Back to Top