import javax.enterprise.concurrent.ManagedTask; //导入依赖的package包/类
public static Runnable buildManagedTask(Runnable task, String identityName) {
	Map<String, String> properties = new HashMap<String, String>(2);
	if (task instanceof SchedulingAwareRunnable) {
		properties.put(ManagedTask.LONGRUNNING_HINT,
				Boolean.toString(((SchedulingAwareRunnable) task).isLongLived()));
	}
	properties.put(ManagedTask.IDENTITY_NAME, identityName);
	return ManagedExecutors.managedTask(task, properties, null);
}
 

import javax.enterprise.concurrent.ManagedTask; //导入依赖的package包/类
public static Runnable buildManagedTask(Runnable task, String identityName) {
    Map<String, String> properties = new HashMap<String, String>(2);
    if (task instanceof SchedulingAwareRunnable) {
        properties.put(ManagedTask.LONGRUNNING_HINT,
                Boolean.toString(((SchedulingAwareRunnable) task).isLongLived()));
    }
    properties.put(ManagedTask.IDENTITY_NAME, identityName);
    return ManagedExecutors.managedTask(task, properties, null);
}
 

import javax.enterprise.concurrent.ManagedTask; //导入依赖的package包/类
/**
 * Builds the managed task.
 *
 * @param task the task
 * @param identityName the identity name
 * @return the runnable
 */
public static Runnable buildManagedTask(Runnable task, String identityName) {
    Map<String, String> properties = new HashMap<String, String>(2);
    if (task instanceof SchedulingAwareRunnable) {
        properties.put(ManagedTask.LONGRUNNING_HINT,
                Boolean.toString(((SchedulingAwareRunnable) task).isLongLived()));
    }
    properties.put(ManagedTask.IDENTITY_NAME, identityName);
    return ManagedExecutors.managedTask(task, properties, null);
}
 

import javax.enterprise.concurrent.ManagedTask; //导入依赖的package包/类
protected ManagedTaskListenerTask(final Object task) {
    if (ManagedTask.class.isInstance(task)) {
        listener = ManagedTask.class.cast(task).getManagedTaskListener();
    } else {
        listener = NoopManagedTaskListener.INSTANCE;
    }
    this.delegate = task;
}
 

import javax.enterprise.concurrent.ManagedTask; //导入依赖的package包/类
public void start() {
    cs.createContextualProxy(new IWantMyOwnTransaction(), Collections.singletonMap(ManagedTask.TRANSACTION, ManagedTask.SUSPEND), Runnable.class).run();
    try {
        cs.createContextualProxy(new IWantMyTheCallerTransaction(txMgr.getTransaction()), Collections.singletonMap(ManagedTask.TRANSACTION, ManagedTask.USE_TRANSACTION_OF_EXECUTION_THREAD), Runnable.class).run();
    } catch (final SystemException e) {
        fail(e.getMessage());
    }
}
 

import javax.enterprise.concurrent.ManagedTask; //导入依赖的package包/类
private CUHandler(final Object instance, final Map<String, String> props) {
    super(instance);
    this.instance = instance;
    this.properties = props;
    this.suspendTx = ManagedTask.SUSPEND.equals(props.get(ManagedTask.TRANSACTION));
}
 

import javax.enterprise.concurrent.ManagedTask; //导入依赖的package包/类
private static String getTaskId(final Object runnable) {
    if (ManagedTask.class.isInstance(runnable)) {
        return ManagedTask.class.cast(runnable).getExecutionProperties().get(ManagedTask.IDENTITY_NAME);
    }
    return null;
}