import de.netsysit.util.threads.CubbyHole;
import java.time.Clock;

public class TimedThrottleValve<T> extends java.lang.Object implements java.lang.Runnable
{
	private final static org.slf4j.Logger CLASS_LOGGER =org.slf4j.LoggerFactory.getLogger(TimedThrottleValve.class);
	private final static org.slf4j.Logger EXCEPTION_LOGGER =org.slf4j.LoggerFactory.getLogger("ExceptionCatcher");
	private final long leastTimeBetweenTasks;
	private long lastGetTimestamp;
	private long burst;
	private final de.netsysit.util.threads.CubbyHole<T> entry;
	private final de.netsysit.util.threads.CubbyHole<T> exit;
	private long burstcounter;

	public TimedThrottleValve(CubbyHole<T> entry, CubbyHole<T> exit, long leastTimeBetweenTasks)
	{
		this(entry,exit,leastTimeBetweenTasks,1);
	}
	public TimedThrottleValve(CubbyHole<T> entry, CubbyHole<T> exit, long leastTimeBetweenTasks, long burst)
	{
		super();
		if(leastTimeBetweenTasks<0)
			throw new java.lang.IllegalArgumentException("leastTimeBetweenTasks must not be less than 0!");
		if(burst<1)
			throw new java.lang.IllegalArgumentException("burst must not be less than 1!");
		this.entry = entry;
		this.exit = exit;
		this.leastTimeBetweenTasks=leastTimeBetweenTasks;
		this.burst=burst;
	}

	@Override
	public void run()
	{
		while(true)
		{
			try
			{
				T item=entry.get();
				if(burstcounter<burst)
					++burstcounter;
				long now = Clock.systemDefaultZone().millis();
				long span = now - lastGetTimestamp;
				CLASS_LOGGER.debug("span {} burst{} burstcounter {}", span,burst,burstcounter);
				if (span >= leastTimeBetweenTasks)
					burstcounter=0;
				if(burstcounter==burst)
				{
					if (span < leastTimeBetweenTasks)
					{
						long l = leastTimeBetweenTasks - (now - lastGetTimestamp);
						CLASS_LOGGER.debug("Sleeping for {} millis...", l);
						java.lang.Thread.currentThread().sleep(leastTimeBetweenTasks);
					}
				}
				exit.put(item);
				lastGetTimestamp=Clock.systemDefaultZone().millis();
			}
			catch(java.lang.InterruptedException exp)
			{

			}
		}
	}
}