Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 6 of 6 for SynchronousQueue (0.2 sec)

  1. android/guava/src/com/google/common/collect/Queues.java

        Iterables.addAll(queue, elements);
        return queue;
      }
    
      // SynchronousQueue
    
      /** Creates an empty {@code SynchronousQueue} with nonfair access policy. */
      @J2ktIncompatible
      @GwtIncompatible // SynchronousQueue
      public static <E> SynchronousQueue<E> newSynchronousQueue() {
        return new SynchronousQueue<>();
      }
    
      /**
    Java
    - Registered: Fri May 03 12:43:13 GMT 2024
    - Last Modified: Mon Apr 01 16:15:01 GMT 2024
    - 16K bytes
    - Viewed (0)
  2. src/main/java/org/codelibs/core/collection/CollectionsUtil.java

        }
    
        /**
         * {@link SynchronousQueue}の新しいインスタンスを作成して返します。
         *
         * @param <E>
         *            {@link SynchronousQueue}の要素型
         * @return {@link SynchronousQueue}の新しいインスタンス
         * @see SynchronousQueue#SynchronousQueue()
         */
        public static <E> SynchronousQueue<E> newSynchronousQueue() {
            return new SynchronousQueue<>();
        }
    
        /**
    Java
    - Registered: Fri May 03 20:58:11 GMT 2024
    - Last Modified: Thu Mar 07 01:59:08 GMT 2024
    - 53.9K bytes
    - Viewed (0)
  3. okhttp/src/main/kotlin/okhttp3/internal/concurrent/TaskRunner.kt

     * See the License for the specific language governing permissions and
     * limitations under the License.
     */
    package okhttp3.internal.concurrent
    
    import java.util.concurrent.BlockingQueue
    import java.util.concurrent.SynchronousQueue
    import java.util.concurrent.ThreadFactory
    import java.util.concurrent.ThreadPoolExecutor
    import java.util.concurrent.TimeUnit
    import java.util.concurrent.locks.Condition
    import java.util.concurrent.locks.ReentrantLock
    Plain Text
    - Registered: Fri May 03 11:42:14 GMT 2024
    - Last Modified: Mon Apr 29 00:33:04 GMT 2024
    - 10.6K bytes
    - Viewed (0)
  4. okhttp/src/main/kotlin/okhttp3/Dispatcher.kt

     * limitations under the License.
     */
    package okhttp3
    
    import java.util.ArrayDeque
    import java.util.Collections
    import java.util.Deque
    import java.util.concurrent.ExecutorService
    import java.util.concurrent.SynchronousQueue
    import java.util.concurrent.ThreadPoolExecutor
    import java.util.concurrent.TimeUnit
    import java.util.concurrent.locks.ReentrantLock
    import okhttp3.internal.assertNotHeld
    import okhttp3.internal.connection.Locks.withLock
    Plain Text
    - Registered: Fri May 03 11:42:14 GMT 2024
    - Last Modified: Sat Apr 20 17:03:43 GMT 2024
    - 9K bytes
    - Viewed (0)
  5. okhttp/src/test/java/okhttp3/internal/http2/HttpOverHttp2Test.kt

    import java.util.Arrays
    import java.util.concurrent.BlockingQueue
    import java.util.concurrent.CountDownLatch
    import java.util.concurrent.Executors
    import java.util.concurrent.LinkedBlockingQueue
    import java.util.concurrent.SynchronousQueue
    import java.util.concurrent.TimeUnit
    import java.util.concurrent.TimeoutException
    import java.util.concurrent.atomic.AtomicReference
    import javax.net.ssl.SSLException
    import kotlin.test.assertFailsWith
    Plain Text
    - Registered: Fri May 03 11:42:14 GMT 2024
    - Last Modified: Thu Apr 11 22:09:35 GMT 2024
    - 75.3K bytes
    - Viewed (0)
  6. okhttp/src/test/java/okhttp3/CallTest.kt

    import java.time.Duration
    import java.util.Arrays
    import java.util.concurrent.BlockingQueue
    import java.util.concurrent.CountDownLatch
    import java.util.concurrent.Executors
    import java.util.concurrent.SynchronousQueue
    import java.util.concurrent.TimeUnit
    import java.util.concurrent.atomic.AtomicBoolean
    import java.util.concurrent.atomic.AtomicInteger
    import java.util.concurrent.atomic.AtomicReference
    import javax.net.ssl.SSLException
    Plain Text
    - Registered: Fri May 03 11:42:14 GMT 2024
    - Last Modified: Wed Apr 10 19:46:48 GMT 2024
    - 142.5K bytes
    - Viewed (0)
Back to top