Search Options

Results per page
Sort
Preferred Languages
Advance

Results 21 - 30 of 341 for synchronized (0.07 sec)

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

       * into user code.
       *
       * @param enqueuedCall a call to enqueue in the synchronized block
       * @param finishedCall a call to finish in the synchronized block
       * @param finishedAsyncCall an async call to finish in the synchronized block
       */
      private fun promoteAndExecute(
        enqueuedCall: AsyncCall? = null,
        finishedCall: RealCall? = null,
    Registered: Fri Dec 26 11:42:13 UTC 2025
    - Last Modified: Tue Oct 07 14:16:22 UTC 2025
    - 9.9K bytes
    - Viewed (0)
  2. android/guava-tests/test/com/google/common/collect/SynchronizedMapTest.java

     * limitations under the License.
     */
    
    package com.google.common.collect;
    
    import static com.google.common.base.Preconditions.checkNotNull;
    
    import com.google.common.collect.Synchronized.SynchronizedCollection;
    import com.google.common.collect.Synchronized.SynchronizedSet;
    import com.google.common.testing.SerializableTester;
    import java.io.Serializable;
    import java.util.Collection;
    import java.util.HashMap;
    import java.util.Map;
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Fri Jul 18 14:47:20 UTC 2025
    - 5.9K bytes
    - Viewed (0)
  3. android/guava-testlib/src/com/google/common/testing/TestLogHandler.java

      @Override
      public void publish(@Nullable LogRecord record) {
        synchronized (lock) {
          if (record != null) {
            list.add(record);
          }
        }
      }
    
      @Override
      public void flush() {}
    
      @Override
      public void close() {}
    
      public void clear() {
        synchronized (lock) {
          list.clear();
        }
      }
    
      /** Returns a snapshot of the logged records. */
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Sun Dec 22 03:38:46 UTC 2024
    - 2.8K bytes
    - Viewed (0)
  4. src/main/java/jcifs/smb/SmbTreeConnection.java

         * @return
         */
        private synchronized SmbTreeImpl getTreeInternal() {
            final SmbTreeImpl t = this.tree;
            if (t != null) {
                return t;
            }
            if (this.delegate != null) {
                return this.delegate.getTreeInternal();
            }
            return null;
        }
    
        /**
         * @param t
         */
        private synchronized void switchTree(final SmbTreeImpl t) {
    Registered: Sat Dec 20 13:44:44 UTC 2025
    - Last Modified: Sat Aug 30 05:58:03 UTC 2025
    - 30.4K bytes
    - Viewed (1)
  5. okhttp/src/jvmTest/kotlin/okhttp3/RecordingCallback.kt

     */
    class RecordingCallback : Callback {
      private val responses = mutableListOf<RecordedResponse>()
    
      @Synchronized
      override fun onFailure(
        call: Call,
        e: IOException,
      ) {
        responses.add(RecordedResponse(call.request(), null, null, null, e))
        (this as Object).notifyAll()
      }
    
      @Synchronized
      override fun onResponse(
        call: Call,
        response: Response,
      ) {
    Registered: Fri Dec 26 11:42:13 UTC 2025
    - Last Modified: Fri Dec 27 13:39:56 UTC 2024
    - 2.1K bytes
    - Viewed (0)
  6. android/guava/src/com/google/common/collect/Tables.java

       *
       * @param table the table to be wrapped in a synchronized view
       * @return a synchronized view of the specified table
       * @since 22.0
       */
      @J2ktIncompatible // Synchronized
      public static <R extends @Nullable Object, C extends @Nullable Object, V extends @Nullable Object>
          Table<R, C, V> synchronizedTable(Table<R, C, V> table) {
        return Synchronized.table(table, null);
      }
    
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Mon Sep 22 18:35:44 UTC 2025
    - 24.9K bytes
    - Viewed (0)
  7. android/guava/src/com/google/common/util/concurrent/ListenerCallQueue.java

        enqueueHelper(event, label);
      }
    
      private void enqueueHelper(Event<L> event, Object label) {
        checkNotNull(event, "event");
        checkNotNull(label, "label");
        synchronized (listeners) {
          for (PerListenerQueue<L> queue : listeners) {
            queue.add(event, label);
          }
        }
      }
    
      /**
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Tue May 13 17:27:14 UTC 2025
    - 8.1K bytes
    - Viewed (0)
  8. src/main/java/jcifs/smb1/smb1/TestLocking.java

                final SmbFile d = new SmbFile(f.getParent());
                final byte[] buf = new byte[1024];
    
                for (int ii = 0; ii < numIter; ii++) {
    
                    synchronized (this) {
                        ltime = System.currentTimeMillis();
                        wait();
                    }
    
                    try {
                        final double r = Math.random();
    Registered: Sat Dec 20 13:44:44 UTC 2025
    - Last Modified: Sat Aug 30 05:58:03 UTC 2025
    - 4.2K bytes
    - Viewed (0)
  9. guava-tests/test/com/google/common/util/concurrent/FutureCallbackTest.java

        }
    
        @Override
        public void onSuccess(String result) {
          synchronized (monitor) {
            assertFalse(wasCalled);
            wasCalled = true;
            assertEquals(value, result);
          }
        }
    
        @Override
        public synchronized void onFailure(Throwable t) {
          synchronized (monitor) {
            assertFalse(wasCalled);
            wasCalled = true;
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Mon Jul 14 14:44:08 UTC 2025
    - 6.7K bytes
    - Viewed (0)
  10. src/main/java/org/codelibs/fess/dict/protwords/ProtwordsFile.java

        }
    
        @Override
        public synchronized void insert(final ProtwordsItem item) {
            try (ProtwordsUpdater updater = new ProtwordsUpdater(item)) {
                reload(updater);
            }
        }
    
        @Override
        public synchronized void update(final ProtwordsItem item) {
            try (ProtwordsUpdater updater = new ProtwordsUpdater(item)) {
    Registered: Sat Dec 20 09:19:18 UTC 2025
    - Last Modified: Thu Nov 20 07:09:00 UTC 2025
    - 11.9K bytes
    - Viewed (0)
Back to top