3f20b8adee
Motivation: If the rate at which new timeouts are created is very high and the created timeouts are not cancelled, then the JVM can crash because of out of heap space. There should be a guard in the implementation to prevent this. Modifications: The constructor of HashedWheelTimer now takes an optional max pending timeouts parameter beyond which it will reject new timeouts by throwing RejectedExecutionException. Result: After this change, if the max pending timeouts parameter is passed as constructor argument to HashedWheelTimer, then it keeps a track of pending timeouts that aren't yet expired or cancelled. When a new timeout is being created, it checks for current pending timeouts and if it's equal to or greater than provided max pending timeouts, then it throws RejectedExecutionException.
49 lines
1.7 KiB
Java
49 lines
1.7 KiB
Java
/*
|
|
* Copyright 2012 The Netty Project
|
|
*
|
|
* The Netty Project 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 io.netty.util;
|
|
|
|
import java.util.Set;
|
|
import java.util.concurrent.RejectedExecutionException;
|
|
import java.util.concurrent.TimeUnit;
|
|
|
|
/**
|
|
* Schedules {@link TimerTask}s for one-time future execution in a background
|
|
* thread.
|
|
*/
|
|
public interface Timer {
|
|
|
|
/**
|
|
* Schedules the specified {@link TimerTask} for one-time execution after
|
|
* the specified delay.
|
|
*
|
|
* @return a handle which is associated with the specified task
|
|
*
|
|
* @throws IllegalStateException if this timer has been {@linkplain #stop() stopped} already
|
|
* @throws RejectedExecutionException if the pending timeouts are too many and creating new timeout
|
|
* can cause instability in the system.
|
|
*/
|
|
Timeout newTimeout(TimerTask task, long delay, TimeUnit unit);
|
|
|
|
/**
|
|
* Releases all resources acquired by this {@link Timer} and cancels all
|
|
* tasks which were scheduled but not executed yet.
|
|
*
|
|
* @return the handles associated with the tasks which were canceled by
|
|
* this method
|
|
*/
|
|
Set<Timeout> stop();
|
|
}
|