/* * Copyright 2002-2018 the original author or authors. * * Licensed 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 * * https://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.springframework.scheduling.commonj;import java.util.Date;import java.util.concurrent.Delayed;import java.util.concurrent.FutureTask;import java.util.concurrent.ScheduledFuture;import java.util.concurrent.TimeUnit;import commonj.timers.Timer;import commonj.timers.TimerListener;import org.springframework.lang.Nullable;import org.springframework.scheduling.TaskScheduler;import org.springframework.scheduling.Trigger;import org.springframework.scheduling.support.SimpleTriggerContext;import org.springframework.scheduling.support.TaskUtils;import org.springframework.util.Assert;import org.springframework.util.ErrorHandler;/** * Implementation of Spring's {@link TaskScheduler} interface, wrapping * a CommonJ {@link commonj.timers.TimerManager}. * * @author Juergen Hoeller * @author Mark Fisher * @since 3.0 * @deprecated as of 5.1, in favor of EE 7's * {@link org.springframework.scheduling.concurrent.DefaultManagedTaskScheduler} */@Deprecatedpublic class TimerManagerTaskScheduler extends TimerManagerAccessor implements TaskScheduler { @Nullable private volatile ErrorHandler errorHandler; /** * Provide an {@link ErrorHandler} strategy. */ public void setErrorHandler(ErrorHandler errorHandler) { this.errorHandler = errorHandler; } @Override @Nullable public ScheduledFuture<?> schedule(Runnable task, Trigger trigger) { return new ReschedulingTimerListener(errorHandlingTask(task, true), trigger).schedule(); } @Override public ScheduledFuture<?> schedule(Runnable task, Date startTime) { TimerScheduledFuture futureTask = new TimerScheduledFuture(errorHandlingTask(task, false)); Timer timer = obtainTimerManager().schedule(futureTask, startTime); futureTask.setTimer(timer); return futureTask; } @Override public ScheduledFuture<?> scheduleAtFixedRate(Runnable task, Date startTime, long period) { TimerScheduledFuture futureTask = new Timer