- Sort Score
- Result 10 results
- Languages All
Results 151 - 160 of 329 for Queues (0.14 sec)
-
android/guava-testlib/src/com/google/common/collect/testing/QueueTestSuiteBuilder.java
import com.google.errorprone.annotations.CanIgnoreReturnValue; import java.util.ArrayList; import java.util.List; /** * Creates, based on your criteria, a JUnit test suite that exhaustively tests a queue * implementation. * * @author Jared Levy */ @GwtIncompatible public final class QueueTestSuiteBuilder<E> extends AbstractCollectionTestSuiteBuilder<QueueTestSuiteBuilder<E>, E> {
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Mon Feb 26 19:46:10 UTC 2024 - 2.5K bytes - Viewed (0) -
docs/es/docs/advanced/index.md
/// tip | Consejo Las próximas secciones **no son necesariamente "avanzadas"**. Y es posible que para tu caso, la solución se encuentre en una de estas. /// ## Lee primero el Tutorial Puedes continuar usando la mayoría de las características de **FastAPI** con el conocimiento del [Tutorial - Guía de Usuario](../tutorial/index.md){.internal-link target=_blank} principal.
Registered: Sun Nov 03 07:19:11 UTC 2024 - Last Modified: Mon Aug 19 18:15:21 UTC 2024 - 830 bytes - Viewed (0) -
android/guava-tests/test/com/google/common/collect/IterablesTest.java
private final Queue<T> queue; UnIterableQueue(Queue<T> queue) { this.queue = queue; } @Override public Iterator<T> iterator() { throw new UnsupportedOperationException(); } @Override protected Queue<T> delegate() { return queue; } } public void testIndexOf_empty() {
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Wed Oct 30 19:12:33 UTC 2024 - 45K bytes - Viewed (0) -
build-logic-commons/basics/src/main/kotlin/gradlebuild/basics/BuildEnvironment.kt
// pre-test/master/queue/alice/feature -> master // pre-test/release/current/bob/bugfix -> release // gh-readonly-queue/master/pr-1234-5678abcdef -> master fun toMergeQueueBaseBranch(actualBranch: String): String = when { actualBranch.startsWith("pre-test/") || actualBranch.startsWith("gh-readonly-queue/") -> actualBranch.substringAfter("/").substringBefore("/") else -> actualBranch }
Registered: Wed Nov 06 11:36:14 UTC 2024 - Last Modified: Wed Oct 09 08:19:42 UTC 2024 - 4.9K bytes - Viewed (0) -
docs/es/docs/async.md
### Concurrencia + Paralelismo: Web + Machine Learning Con **FastAPI** puedes aprovechar la concurrencia que es muy común para el desarrollo web (atractivo principal de NodeJS).
Registered: Sun Nov 03 07:19:11 UTC 2024 - Last Modified: Mon Aug 19 18:15:21 UTC 2024 - 24.9K bytes - Viewed (0) -
okhttp-testing-support/src/main/kotlin/okhttp3/internal/concurrent/TaskFaker.kt
waitingCoordinatorInterrupted = false throw InterruptedException() } } override fun <T> decorate(queue: BlockingQueue<T>) = TaskFakerBlockingQueue(queue) }, logger = logger, ) /** Runs all tasks that are ready. Used by the test thread only. */ fun runTasks() { advanceUntil(nanoTime) }
Registered: Fri Nov 01 11:42:11 UTC 2024 - Last Modified: Mon Apr 29 00:33:04 UTC 2024 - 12.6K bytes - Viewed (0) -
build-logic-commons/basics/src/main/kotlin/gradlebuild/basics/BuildParams.kt
/** * The logical branch. * For non-merge-queue branches this is the same as {@link #buildBranch}. * For merge-queue branches, this is the base branch. * * For example, for the merge queue branch "gh-readonly-queue/master/pr-12345-1a2b3c4d" the logical branch is "master". */ val Project.logicalBranch: Provider<String>
Registered: Wed Nov 06 11:36:14 UTC 2024 - Last Modified: Wed Oct 09 08:19:42 UTC 2024 - 16.9K bytes - Viewed (0) -
cmd/site-replication-metrics.go
// Total Replica size in bytes ReplicaSize int64 `json:"replicaSize"` // Total number of replica received ReplicaCount int64 `json:"replicaCount"` // Queued operations Queued InQueueMetric `json:"queued"` // Proxy stats Proxied ProxyMetric `json:"proxied"` // replication metrics summary for each site replication peer Metrics map[string]SRMetric `json:"replMetrics"`
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Tue Feb 06 06:00:45 UTC 2024 - 8.2K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/suggest/concurrent/Deferred.java
private RESPONSE response = null; private Throwable error = null; private final Promise promise = new Promise(); private final Queue<Consumer<RESPONSE>> doneCallbacks = new LinkedBlockingQueue<>(); private final Queue<Consumer<Throwable>> errorCallbacks = new LinkedBlockingQueue<>(); private final CountDownLatch latch = new CountDownLatch(1); public void resolve(final RESPONSE r) {
Registered: Fri Nov 08 09:08:12 UTC 2024 - Last Modified: Thu Feb 22 01:36:54 UTC 2024 - 5.4K bytes - Viewed (0) -
src/main/java/org/codelibs/core/crypto/CachedCipher.java
protected String transformation = RSA; protected String key; protected String charsetName = CoreLibConstants.UTF_8; protected Queue<Cipher> encryptoQueue = new ConcurrentLinkedQueue<>(); protected Queue<Cipher> decryptoQueue = new ConcurrentLinkedQueue<>(); public byte[] encrypto(final byte[] data) { final Cipher cipher = pollEncryptoCipher(); byte[] encrypted;
Registered: Fri Nov 01 20:58:10 UTC 2024 - Last Modified: Thu Mar 07 01:59:08 UTC 2024 - 8.1K bytes - Viewed (0)