| /* |
| * Licensed to the Apache Software Foundation (ASF) under one |
| * or more contributor license agreements. See the NOTICE file |
| * distributed with this work for additional information |
| * regarding copyright ownership. The ASF licenses this file |
| * to you under the Apache License, Version 2.0 (the |
| * "License"); you may not use this file except in compliance |
| * with the License. You may obtain a copy of the License at |
| * |
| * http://www.apache.org/licenses/LICENSE-2.0 |
| * |
| * Unless required by applicable law or agreed to in writing, |
| * software distributed under the License is distributed on an |
| * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY |
| * KIND, either express or implied. See the License for the |
| * specific language governing permissions and limitations |
| * under the License. |
| */ |
| package org.apache.brooklyn.api.mgmt; |
| |
| import java.util.Collection; |
| import java.util.Map; |
| import java.util.Set; |
| import java.util.concurrent.Callable; |
| import java.util.concurrent.ExecutorService; |
| |
| import org.apache.brooklyn.api.entity.Entity; |
| |
| /** |
| * This class manages the execution of a number of jobs with tags. |
| * |
| * It is like an executor service (and it ends up delegating to one) but adds additional support |
| * where jobs can be: |
| * <ul> |
| * <li>Tracked with tags/buckets |
| * <li>Be {@link Runnable}s or {@link Callable}s, (support for {@link groovy.lang.Closure} is deprecated) |
| * <li>Remembered after completion |
| * <li>Treated as {@link Task} instances (see below) |
| * <li>Given powerful synchronization capabilities |
| * </ul> |
| * <p> |
| * The advantage of treating them as {@link Task} instances include: |
| * <ul> |
| * <li>Richer status information |
| * <li>Started-by, contained-by relationships automatically remembered |
| * <li>Runtime metadata (start, stop, etc) |
| * <li>Grid and multi-machine support) |
| * </ul> |
| * <p> |
| * For usage instructions see {@link #submit(Map, TaskAdaptable)}, and for examples see the various |
| * {@code ExecutionTest} and {@code TaskTest} instances. |
| * <p> |
| * It has been developed for multi-location provisioning and management to track work being |
| * done by each {@link Entity}. |
| * <p> |
| * Note the use of the environment variable {@code THREAD_POOL_SIZE} which is used to size |
| * the {@link ExecutorService} thread pool. The default is calculated as twice the number |
| * of CPUs in the system plus two, giving 10 for a four core system, 18 for an eight CPU |
| * server and so on. |
| */ |
| public interface ExecutionManager { |
| public boolean isShutdown(); |
| |
| /** returns the task with the given ID, or null if none */ |
| public Task<?> getTask(String id); |
| |
| /** returns all tasks with the given tag (immutable) */ |
| public Set<Task<?>> getTasksWithTag(Object tag); |
| |
| /** returns all tasks that have any of the given tags (immutable) */ |
| public Set<Task<?>> getTasksWithAnyTag(Iterable<?> tags); |
| |
| /** returns all tasks that have all of the given tags (immutable) */ |
| public Set<Task<?>> getTasksWithAllTags(Iterable<?> tags); |
| |
| /** returns all tags known to this manager (immutable) */ |
| public Set<Object> getTaskTags(); |
| |
| // /** returns all tasks known to this manager (immutable) */ |
| // public Set<Task<?>> getAllTasks(); |
| |
| /** see {@link #submit(Map, TaskAdaptable)} |
| * @deprecated since 1.0.0 pass displayName or map */ |
| @Deprecated |
| public Task<?> submit(Runnable r); |
| |
| /** see {@link #submit(Map, TaskAdaptable)} |
| * @deprecated since 1.0.0 pass displayName or map */ |
| @Deprecated |
| public <T> Task<T> submit(Callable<T> r); |
| |
| /** see {@link #submit(Map, TaskAdaptable)} */ |
| public Task<?> submit(String displayName, Runnable c); |
| |
| /** see {@link #submit(Map, TaskAdaptable)} */ |
| public <T> Task<T> submit(String displayName, Callable<T> c); |
| |
| /** see {@link #submit(Map, TaskAdaptable)} */ |
| public <T> Task<T> submit(TaskAdaptable<T> task); |
| |
| /** see {@link #submit(Map, TaskAdaptable)} */ |
| public Task<?> submit(Map<?, ?> flags, Runnable r); |
| |
| /** see {@link #submit(Map, TaskAdaptable)} */ |
| public <T> Task<T> submit(Map<?, ?> flags, Callable<T> c); |
| |
| /** |
| * Submits the given {@link Task} for execution in the context associated with this manager. |
| * |
| * The following optional flags supported (in the optional map first arg): |
| * <ul> |
| * <li><em>tag</em> - A single object to be used as a tag for looking up the task |
| * <li><em>tags</em> - A {@link Collection} of object tags each of which the task should be associated, |
| * used for associating with contexts, mutex execution, and other purposes |
| * <li><em>synchId</em> - A string, or {@link Collection} of strings, representing a category on which an object should own a synch lock |
| * <li><em>synchObj</em> - A string, or {@link Collection} of strings, representing a category on which an object should own a synch lock |
| * <li><em>newTaskStartCallback</em> - A callback that will be invoked just before the task starts if it starts as a result of this call. |
| * <li><em>newTaskEndCallback</em> - A callback that will be invoked when the task completes if it starts as a result of this call |
| * </ul> |
| * |
| * Callbacks run in the task's thread. It can be one of the following types: |
| * <ul> |
| * <li>{@link Runnable} |
| * <li>{@link Callable} |
| * <li>{@link com.google.common.base.Function} that matches the generics {@code <? super Task, ?>} |
| * <li>Support for {@link groovy.lang.Closure} is deprecated. |
| * </ul> |
| * <p> |
| * If a Map is supplied it must be modifiable (currently; may allow immutable maps in future). |
| */ |
| public <T> Task<T> submit(Map<?, ?> flags, TaskAdaptable<T> task); |
| |
| } |