- Sort Score
- Result 10 results
- Languages All
Results 1 - 8 of 8 for createActor (0.24 sec)
-
platforms/core-runtime/messaging/src/test/groovy/org/gradle/internal/actor/internal/DefaultActorFactorySpec.groovy
} def createsANonBlockingActorForATargetObject() { when: def actor = factory.createActor(target) then: actor != null } def cachesTheNonBlockingActorForATargetObject() { when: def actor1 = factory.createActor(target) def actor2 = factory.createActor(target) then: actor2.is(actor1) }
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Sep 22 08:59:22 UTC 2023 - 8.1K bytes - Viewed (0) -
platforms/software/testing-base/src/test/groovy/org/gradle/api/internal/tasks/testing/processors/MaxNParallelTestClassProcessorTest.groovy
then: 1 * factory.create() >> processor1 1 * actorFactory.createActor(processor1) >> actor1 1 * actor1.getProxy(TestClassProcessor) >> asyncProcessor1 when: processor.processTestClass(test) then: 1 * factory.create() >> processor2 1 * actorFactory.createActor(processor2) >> actor2 1 * actor2.getProxy(TestClassProcessor) >> asyncProcessor2
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Mon Sep 18 20:52:40 UTC 2023 - 6.4K bytes - Viewed (0) -
platforms/software/testing-base/src/main/java/org/gradle/api/internal/tasks/testing/processors/MaxNParallelTestClassProcessor.java
} @Override public void startProcessing(TestResultProcessor resultProcessor) { // Create a processor that processes events in its own thread resultProcessorActor = actorFactory.createActor(resultProcessor); this.resultProcessor = resultProcessorActor.getProxy(TestResultProcessor.class); } @Override public void processTestClass(TestClassRunInfo testClass) { if (stoppedNow) {
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Mon Sep 18 20:52:40 UTC 2023 - 3.6K bytes - Viewed (0) -
platforms/core-runtime/messaging/src/main/java/org/gradle/internal/actor/ActorFactory.java
public interface ActorFactory { /** * Creates an asynchronous actor for the given target object. * * @param target The target object. * @return The actor. */ Actor createActor(Object target); /** * Creates a synchronous actor for the given target object. * * @param target The target object. * @return The actor. */
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Sep 22 08:59:22 UTC 2023 - 1.1K bytes - Viewed (0) -
platforms/core-runtime/messaging/src/testFixtures/groovy/org/gradle/internal/actor/TestActorFactory.java
import org.gradle.internal.dispatch.ProxyDispatchAdapter; import org.gradle.internal.dispatch.ReflectionDispatch; public class TestActorFactory implements ActorFactory { @Override public Actor createActor(Object target) { throw new UnsupportedOperationException(); } @Override public Actor createBlockingActor(final Object target) { return new Actor() { @Override
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Sep 22 08:59:22 UTC 2023 - 1.6K bytes - Viewed (0) -
platforms/core-runtime/messaging/src/main/java/org/gradle/internal/actor/internal/DefaultActorFactory.java
} finally { nonBlockingActors.clear(); } } } @Override public Actor createActor(Object target) { if (target instanceof NonBlockingActor) { return (NonBlockingActor) target; } synchronized (lock) { if (blockingActors.containsKey(target)) {
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Tue May 28 13:09:37 UTC 2024 - 6.3K bytes - Viewed (0) -
tensorflow/compiler/mlir/lite/experimental/tac/execution_metadata_exporter_test.cc
CreateOpMetadata( fb_builder, 3, 1, fb_builder.CreateVector(std::vector<float>({-1.0, 2.0}))), }; const auto subgraphs = {CreateSubgraphMetadata( fb_builder, fb_builder.CreateVector(ops.begin(), ops.size()))}; const auto metadata = CreateRuntimeMetadata( fb_builder, hardwares, fb_builder.CreateVector(subgraphs.begin(), subgraphs.size()));
Registered: Sun Jun 16 05:45:23 UTC 2024 - Last Modified: Tue Jun 11 06:11:34 UTC 2024 - 6K bytes - Viewed (0) -
tensorflow/compiler/mlir/lite/experimental/tac/execution_metadata_exporter.cc
flatbuffers::Offset<flatbuffers::Vector<float>> per_device_cost_offset; if (per_device_cost.has_value()) { per_device_cost_offset = builder->CreateVector(*per_device_cost); } OpMetadataBuilder op_builder(*builder); op_builder.add_index(index); uint8_t hardware = hardware_map.at(*device_name); op_builder.add_hardware(hardware);
Registered: Sun Jun 16 05:45:23 UTC 2024 - Last Modified: Tue Jun 11 06:11:34 UTC 2024 - 7.5K bytes - Viewed (0)