import javax.enterprise.concurrent.LastExecution; //导入依赖的package包/类
public ScheduledFuture<?> schedule(Runnable task, final Trigger trigger) {
	ManagedScheduledExecutorService executor = (ManagedScheduledExecutorService) scheduledExecutor;
	return executor.schedule(task, new javax.enterprise.concurrent.Trigger() {
		@Override
		public Date getNextRunTime(LastExecution le, Date taskScheduledTime) {
			return trigger.nextExecutionTime(le != null ?
					new SimpleTriggerContext(le.getScheduledStart(), le.getRunStart(), le.getRunEnd()) :
					new SimpleTriggerContext());
		}
		@Override
		public boolean skipRun(LastExecution lastExecution, Date scheduledRunTime) {
			return false;
		}
	});
}
 

import javax.enterprise.concurrent.LastExecution; //导入依赖的package包/类
public ScheduledFuture<?> schedule(Runnable task, final Trigger trigger) {
    ManagedScheduledExecutorService executor = (ManagedScheduledExecutorService) scheduledExecutor;
    return executor.schedule(task, new javax.enterprise.concurrent.Trigger() {
        @Override
        public Date getNextRunTime(LastExecution le, Date taskScheduledTime) {
            return trigger.nextExecutionTime(le != null ? new SimpleTriggerContext(le.getScheduledStart(), le
                    .getRunStart(), le.getRunEnd()) : new SimpleTriggerContext());
        }

        @Override
        public boolean skipRun(LastExecution lastExecution, Date scheduledRunTime) {
            return false;
        }
    });
}
 

import javax.enterprise.concurrent.LastExecution; //导入依赖的package包/类
/**
 * Schedule.
 * 
 * @param task
 *            the task
 * @param trigger
 *            the trigger
 * @return the scheduled future
 */
public ScheduledFuture<?> schedule(Runnable task, final Trigger trigger) {
    ManagedScheduledExecutorService executor = (ManagedScheduledExecutorService) scheduledExecutor;
    return executor.schedule(task, new javax.enterprise.concurrent.Trigger() {
        @Override
        public Date getNextRunTime(LastExecution le, Date taskScheduledTime) {
            return trigger.nextExecutionTime(le != null ? new SimpleTriggerContext(le.getScheduledStart(), le
                    .getRunStart(), le.getRunEnd()) : new SimpleTriggerContext());
        }

        @Override
        public boolean skipRun(LastExecution lastExecution, Date scheduledRunTime) {
            return false;
        }
    });
}
 

import javax.enterprise.concurrent.LastExecution; //导入依赖的package包/类
@Override
public Date getNextRunTime(LastExecution le, Date taskScheduledDate) {
    if (le == null) {
        return new Date(taskScheduledDate.getTime() + 5000);
    }
    if (System.currentTimeMillis() > taskScheduledDate.getTime() + 30000L) {
        // stops task 30 seconds after task was originally scheduled
        System.out.println("Trigger done");
        return null;
    }
    return new Date(le.getRunStart().getTime() + 5000);
}
 

import javax.enterprise.concurrent.LastExecution; //导入依赖的package包/类
@Override
public Date getNextRunTime(LastExecution le, Date date) {
    throw new UnsupportedOperationException("Not supported yet."); //To change body of generated methods, choose Tools | Templates.
}
 

import javax.enterprise.concurrent.LastExecution; //导入依赖的package包/类
@Override
public boolean skipRun(LastExecution le, Date date) {
    throw new UnsupportedOperationException("Not supported yet."); //To change body of generated methods, choose Tools | Templates.
}
 

import javax.enterprise.concurrent.LastExecution; //导入依赖的package包/类
@Override
public boolean skipRun(LastExecution le, Date date) {
    return false;
}
 

import javax.enterprise.concurrent.LastExecution; //导入依赖的package包/类
public LastExecution getLastExecution() {
    return lastExecution;
}