- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 22 for LinkedBlockingQueue (0.4 sec)
-
android/guava/src/com/google/common/collect/Queues.java
Iterables.addAll(deque, elements); return deque; } // LinkedBlockingQueue /** Creates an empty {@code LinkedBlockingQueue} with a capacity of {@link Integer#MAX_VALUE}. */ @J2ktIncompatible @GwtIncompatible // LinkedBlockingQueue public static <E> LinkedBlockingQueue<E> newLinkedBlockingQueue() { return new LinkedBlockingQueue<>(); } /**
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Mon Apr 01 16:15:01 GMT 2024 - 16K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/TestLogHandler.kt
* See the License for the specific language governing permissions and * limitations under the License. */ package okhttp3 import java.util.concurrent.LinkedBlockingQueue import java.util.concurrent.TimeUnit import java.util.logging.Handler import java.util.logging.Level import java.util.logging.LogRecord import java.util.logging.Logger
Plain Text - Registered: Fri Apr 26 11:42:10 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 2.6K bytes - Viewed (0) -
mockwebserver/src/main/kotlin/mockwebserver3/QueueDispatcher.kt
import java.util.concurrent.LinkedBlockingQueue import java.util.logging.Logger import okhttp3.ExperimentalOkHttpApi /** * Default dispatcher that processes a script of responses. Populate the script by calling [enqueueResponse]. */ @ExperimentalOkHttpApi open class QueueDispatcher : Dispatcher() { protected val responseQueue: BlockingQueue<MockResponse> = LinkedBlockingQueue()
Plain Text - Registered: Fri Apr 26 11:42:10 GMT 2024 - Last Modified: Tue Jan 23 14:31:42 GMT 2024 - 3K bytes - Viewed (0) -
src/main/java/org/codelibs/core/collection/CollectionsUtil.java
} /** * {@link LinkedBlockingQueue}の新しいインスタンスを作成して返します。 * * @param <E> * {@link LinkedBlockingQueue}の要素型 * @return {@link LinkedBlockingQueue}の新しいインスタンス * @see LinkedBlockingQueue#LinkedBlockingQueue() */ public static <E> LinkedBlockingQueue<E> newLinkedBlockingQueue() { return new LinkedBlockingQueue<>(); } /**
Java - Registered: Fri Apr 26 20:58:09 GMT 2024 - Last Modified: Thu Mar 07 01:59:08 GMT 2024 - 53.9K bytes - Viewed (0) -
mockwebserver/src/main/kotlin/mockwebserver3/internal/duplex/MockStreamHandler.kt
* [receiveRequest] in the sequence they are run. */ class MockStreamHandler : StreamHandler { private val actions = LinkedBlockingQueue<Action>() private val results = LinkedBlockingQueue<FutureTask<Void>>() fun receiveRequest(expected: String) = apply { actions += { stream -> val actual = stream.requestBody.readUtf8(expected.utf8Size())
Plain Text - Registered: Fri Apr 26 11:42:10 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 3.2K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/collect/QueuesTest.java
*/ public static List<BlockingQueue<Object>> blockingQueues() { return ImmutableList.<BlockingQueue<Object>>of( new LinkedBlockingQueue<Object>(), new LinkedBlockingQueue<Object>(10), new SynchronousQueue<Object>(), new ArrayBlockingQueue<Object>(10), new LinkedBlockingDeque<Object>(), new LinkedBlockingDeque<Object>(10),
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Wed Sep 06 17:04:31 GMT 2023 - 12K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/internal/ws/WebSocketRecorder.kt
import java.io.IOException import java.util.concurrent.LinkedBlockingQueue import java.util.concurrent.TimeUnit import okhttp3.Response import okhttp3.WebSocket import okhttp3.WebSocketListener import okhttp3.internal.platform.Platform import okio.ByteString class WebSocketRecorder( private val name: String, ) : WebSocketListener() { private val events = LinkedBlockingQueue<Any>() private var delegate: WebSocketListener? = null
Plain Text - Registered: Fri Apr 26 11:42:10 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 6.9K bytes - Viewed (0) -
okhttp-testing-support/src/main/kotlin/okhttp3/internal/duplex/AsyncRequestBody.kt
* See the License for the specific language governing permissions and * limitations under the License. */ package okhttp3.internal.duplex import java.util.concurrent.BlockingQueue import java.util.concurrent.LinkedBlockingQueue import java.util.concurrent.TimeUnit.SECONDS import okhttp3.MediaType import okhttp3.RequestBody import okio.BufferedSink import org.junit.jupiter.api.Assertions.assertTrue
Plain Text - Registered: Fri Apr 26 11:42:10 GMT 2024 - Last Modified: Wed Dec 20 23:27:07 GMT 2023 - 1.5K bytes - Viewed (0) -
samples/crawler/src/main/java/okhttp3/sample/Crawler.java
*/ public final class Crawler { private final OkHttpClient client; private final Set<HttpUrl> fetchedUrls = Collections.synchronizedSet(new LinkedHashSet<>()); private final LinkedBlockingQueue<HttpUrl> queue = new LinkedBlockingQueue<>(); private final ConcurrentHashMap<String, AtomicInteger> hostnames = new ConcurrentHashMap<>(); public Crawler(OkHttpClient client) { this.client = client; }
Java - Registered: Fri Apr 26 11:42:10 GMT 2024 - Last Modified: Thu Aug 12 07:26:27 GMT 2021 - 4.6K bytes - Viewed (0) -
android/guava-testlib/src/com/google/common/collect/testing/TestsForQueuesInJavaUtil.java
new TestStringQueueGenerator() { @Override public Queue<String> create(String[] elements) { return new LinkedBlockingQueue<>(MinimalCollection.of(elements)); } }) .named("LinkedBlockingQueue") .withFeatures( CollectionFeature.GENERAL_PURPOSE, CollectionFeature.KNOWN_ORDER, CollectionSize.ANY)
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Mon Dec 04 17:37:03 GMT 2017 - 7.7K bytes - Viewed (0)