#

Junjie

昨天 5d68f36fb16c07ea5459a167c9711f681c2f71b2

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
package com.zy.core.thread.support;
 
import org.junit.jupiter.api.Test;
 
import java.util.concurrent.atomic.AtomicLong;
 
import static org.junit.jupiter.api.Assertions.assertFalse;
import static org.junit.jupiter.api.Assertions.assertTrue;
 
class RecentStationArrivalTrackerTest {
 
    @Test
    void hasRecentArrival_returnsTrueOnlyWithinRetentionWindow() {
        AtomicLong now = new AtomicLong(1_000L);
        RecentStationArrivalTracker tracker = new RecentStationArrivalTracker(1_000L, now::get);
 
        tracker.record(12, 1001);
 
        assertTrue(tracker.hasRecentArrival(12, 1001));
 
        now.addAndGet(1_001L);
 
        assertFalse(tracker.hasRecentArrival(12, 1001));
    }
}