我正在尝试实现令牌桶速率限制器。下面是我编写的基本代码，但没有得到预期的结果。似乎我遗漏了一些东西，或者我还没有完全理解如何在java中线程函数。有人能帮助我寻找正确的方向吗？

public class RateLimiterTokenBucket implements RateLimiter, Runnable{

    Integer capacity;
    Integer frequencyInMilliseconds;
    Integer currentCapacity;

    public RateLimiterTokenBucket(Integer frequencyInMilliseconds,Integer capacity) {
        this.frequencyInMilliseconds = frequencyInMilliseconds;
        this.capacity = capacity;
        this.currentCapacity = capacity;
    }

    @Override
    public boolean consume() {
        synchronized (currentCapacity) {
            if(currentCapacity <= 0) return false;
            --currentCapacity;
            return true;
        }
    }

    @Override
    public void run() {
        synchronized (currentCapacity) {
            OffsetDateTime t = OffsetDateTime.now();
            while(true) {
                if(OffsetDateTime.now().isAfter(t.plus(frequencyInMilliseconds, ChronoUnit.MILLIS))){
                    if(currentCapacity<capacity){
                        System.out.println("token added");
                        ++currentCapacity;
                    }
                    t=OffsetDateTime.now();
                }
            }
        }
    }
}

主类

public static void main(String[] args) {
        RateLimiter rl = new RateLimiterTokenBucket(10,5);
        Thread t = new Thread((Runnable) rl);
        t.start();
        while(true){
            if(rl.consume()) {
                System.out.println(OffsetDateTime.now()+" ---> true");
            }
        }
    }

只是得到

2023-04-29T19:30:54.685553+05:30 ---> true
token added

作为两个线程main和t1仍在运行的输出