- Sort Score
- Result 10 results
- Languages All
Results 41 - 50 of 175 for task (0.15 sec)
-
maven-core/src/test/java/org/apache/maven/lifecycle/internal/stub/LifecycleExecutionPlanCalculatorStub.java
// Maybe do something ? } public MavenExecutionPlan calculateExecutionPlan( MavenSession session, MavenProject project, List<Task> tasks, boolean setup) throws PluginNotFoundException, PluginResolutionException, LifecyclePhaseNotFoundException, PluginDescriptorParsingException, MojoNotFoundException, InvalidPluginDescriptorException,
Java - Registered: Sun Apr 28 03:35:10 GMT 2024 - Last Modified: Tue Jan 09 20:57:17 GMT 2024 - 12.4K bytes - Viewed (0) -
guava-tests/test/com/google/common/util/concurrent/AbstractScheduledServiceTest.java
final CyclicBarrier firstBarrier = new CyclicBarrier(2); final CyclicBarrier secondBarrier = new CyclicBarrier(2); final AtomicBoolean shouldWait = new AtomicBoolean(true); Runnable task = new Runnable() { @Override public void run() { try { if (shouldWait.get()) { firstBarrier.await(); secondBarrier.await();
Java - Registered: Fri Apr 12 12:43:09 GMT 2024 - Last Modified: Wed Sep 06 17:04:31 GMT 2023 - 22.5K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/util/concurrent/AbstractScheduledServiceTest.java
final CyclicBarrier firstBarrier = new CyclicBarrier(2); final CyclicBarrier secondBarrier = new CyclicBarrier(2); final AtomicBoolean shouldWait = new AtomicBoolean(true); Runnable task = new Runnable() { @Override public void run() { try { if (shouldWait.get()) { firstBarrier.await(); secondBarrier.await();
Java - Registered: Fri May 03 12:43:13 GMT 2024 - Last Modified: Wed Sep 06 17:04:31 GMT 2023 - 22.5K bytes - Viewed (0) -
maven-core/src/main/java/org/apache/maven/lifecycle/internal/MojoDescriptorCreator.java
return new org.codehaus.plexus.util.xml.Xpp3Dom(dom); } // org.apache.maven.plugins:maven-remote-resources-plugin:1.0:process@executionId public MojoDescriptor getMojoDescriptor(String task, MavenSession session, MavenProject project) throws PluginNotFoundException, PluginResolutionException, PluginDescriptorParsingException,
Java - Registered: Sun May 05 03:35:11 GMT 2024 - Last Modified: Wed Jan 10 12:55:54 GMT 2024 - 11.5K bytes - Viewed (0) -
maven-core/src/test/java/org/apache/maven/lifecycle/LifecycleExecutorTest.java
MavenSession session = createMavenSession(pom); LifecycleTask task = new LifecycleTask("generate-sources"); MavenExecutionPlan executionPlan = lifeCycleExecutionPlanCalculator.calculateExecutionPlan( session, session.getCurrentProject(), Arrays.asList(task), false); MojoExecution execution = executionPlan.getMojoExecutions().get(0);
Java - Registered: Sun Apr 28 03:35:10 GMT 2024 - Last Modified: Tue Jan 09 20:57:17 GMT 2024 - 24.7K bytes - Viewed (0) -
tests/test_dependency_contextmanager.py
raise OtherDependencyError() @app.get("/context_b_bg") async def get_context_b_bg(tasks: BackgroundTasks, state: dict = Depends(context_b)): async def bg(state: dict): state["bg"] = f"bg set - b: {state['context_b']} - a: {state['context_a']}" tasks.add_task(bg, state) return state # Sync versions @app.get("/sync_async")
Python - Registered: Sun May 05 07:19:11 GMT 2024 - Last Modified: Sat Feb 24 23:06:37 GMT 2024 - 11.6K bytes - Viewed (0) -
tensorflow/c/eager/c_api_experimental.h
// custom devices will fail. // // `device_name` must not name an existing physical or custom device. It must // follow the format: // // /job:<name>/replica:<replica>/task:<task>/device:<type>:<device_num> // // If the device is successfully registered, `status` is set to TF_OK. Otherwise // the device is not usable. In case of a bad status, `device.delete_device` is
C - Registered: Tue Apr 30 12:39:09 GMT 2024 - Last Modified: Wed Feb 21 22:37:46 GMT 2024 - 39.5K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/helper/SystemHelper.java
public void destroy() { shutdownHookList.forEach(action -> { try { action.run(); } catch (final Exception e) { logger.warn("Failed to process shutdown task.", e); } }); } public String getUsername() { final RequestManager requestManager = ComponentUtil.getRequestManager();
Java - Registered: Mon May 06 08:04:11 GMT 2024 - Last Modified: Sat Apr 13 11:43:03 GMT 2024 - 26.5K bytes - Viewed (2) -
cmd/peer-s3-client.go
// buckets only and not the quourum lost ones like this, so // explicit call for bktName, count := range bucketsMap { if count < quorum { // Queue a bucket heal task globalMRFState.addPartialOp(partialOperation{ bucket: bktName, queued: time.Now(), }) } } } result := make([]BucketInfo, 0, len(resultMap))
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 14.8K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/internal/connection/ConnectionPoolTest.kt
class ConnectionPoolTest { private val routePlanner = FakeRoutePlanner() private val factory = routePlanner.factory private val taskFaker = routePlanner.taskFaker private val peer = MockHttp2Peer() /** The fake task runner prevents the cleanup runnable from being started. */ private val addressA = factory.newAddress("a") private val routeA1 = factory.newRoute(addressA) private val addressB = factory.newAddress("b")
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Wed Apr 24 04:40:49 GMT 2024 - 12.7K bytes - Viewed (0)