Java provides a thread-safe unbounded blocking queue in which an element can only be taken when its delay has expired via DelayQueue. Creating a DelayQueue is as simple as the following:

BlockingQueue<TrainDelay> queue = new DelayQueue<>();