- Sort Score
- Result 10 results
- Languages All
Results 1 - 7 of 7 for TestCthread (0.43 sec)
-
testing/internal-testing/src/main/groovy/org/gradle/test/fixtures/concurrent/TestThread.groovy
* limitations under the License. */ package org.gradle.test.fixtures.concurrent /** * Represents the current thread. */ class TestThread { private final Instants instants TestThread(Instants instants) { this.instants = instants } void block() { Thread.sleep(750) } BlockTarget getBlockUntil() {
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu Apr 04 07:21:38 UTC 2024 - 971 bytes - Viewed (0) -
android/guava-tests/test/com/google/common/util/concurrent/TestThread.java
import java.util.concurrent.TimeoutException; import junit.framework.AssertionFailedError; import org.checkerframework.checker.nullness.qual.Nullable; /** * A helper for concurrency testing. One or more {@code TestThread} instances are instantiated in a * test with reference to the same "lock-like object", and then their interactions with that object * are choreographed via the various methods on this class. *
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Tue Jun 11 16:13:05 UTC 2024 - 10.8K bytes - Viewed (0) -
guava-tests/test/com/google/common/util/concurrent/TestThread.java
import java.util.concurrent.TimeoutException; import junit.framework.AssertionFailedError; import org.checkerframework.checker.nullness.qual.Nullable; /** * A helper for concurrency testing. One or more {@code TestThread} instances are instantiated in a * test with reference to the same "lock-like object", and then their interactions with that object * are choreographed via the various methods on this class. *
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Tue Jun 11 16:13:05 UTC 2024 - 10.8K bytes - Viewed (0) -
testing/internal-testing/src/main/groovy/org/gradle/test/fixtures/ConcurrentTestUtil.groovy
void execute(Runnable runnable) { startThread(runnable) } } } TestThread startThread(Runnable cl) { lock.lock() try { TestThread thread = new TestThread(this, lock, cl) thread.start() return thread } finally { lock.unlock() } } /**
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu Apr 04 07:21:38 UTC 2024 - 22.9K bytes - Viewed (0) -
platforms/core-runtime/messaging/src/test/groovy/org/gradle/internal/actor/internal/DefaultActorFactorySpec.groovy
def actor = factory.createBlockingActor(target) def testThread = Thread.currentThread() when: actor.dispatch(new MethodInvocation(TargetObject.class.getMethod('doStuff', String.class), ['param'] as Object[])) then: 1 * target.doStuff('param') >> { assert Thread.currentThread() == testThread } }
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Sep 22 08:59:22 UTC 2023 - 8.1K bytes - Viewed (0) -
testing/internal-testing/src/main/groovy/org/gradle/test/fixtures/concurrent/ConcurrentSpec.groovy
* * @see NamedOperation */ final Operations operation = new Operations(instant, instant) /** * An object that allows control over the current thread. */ final TestThread thread = new TestThread(instant) final BlockTarget waitFor = new BlockTarget(instant) public final TestExecutor executor = new TestExecutor(logger)
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu Apr 04 07:21:38 UTC 2024 - 3.5K bytes - Viewed (0) -
src/internal/trace/traceviewer/static/trace_viewer_full.html
dParser,};});'use strict';tr.exportTo('tr.e.importer.linux_perf',function(){const ColorScheme=tr.b.ColorScheme;const Parser=tr.e.importer.linux_perf.Parser;const binderTransRE=new RegExp('transaction=(\\d+) dest_node=(\\d+) '+'dest_proc=(\\d+) dest_thread=(\\d+) '+'reply=(\\d+) flags=(0x[0-9a-fA-F]+) '+'code=(0x[0-9a-fA-F]+)');const binderAllocRE=new RegExp('transaction=(\\d+) data_size=(\\d+) '+'offsets_size=(\\d+)');const binderTransReceivedRE=/transaction=(\d+)/;function isBinderThread(name){...
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Nov 21 20:45:06 UTC 2023 - 2.5M bytes - Viewed (2)