已关闭。此问题需要details or clarity。目前不接受回答。
**要改进此问题吗？**通过editing this post添加详细信息并阐明问题。

3天前关闭。
Improve this question的
我有一个Consumer类，它应该每秒从队列中删除n个项目，但没有更多：

class Consumer {
    Consumer(int items_per_sec, Storage& storage) : 
        items_per_sec{items_per_sec}, storage{storage} {}
    
    void consume() {
        while (!storage.empty()) {
            for (int i = 0; i < items_per_sec; ++i) {
                storage.consume();
            }
            std::this_thread::sleep_for(1s);
        }
    }
private:
    int items_per_sec;
    Storage& storage;
};

字符串
这里，Storage是一个线程安全的队列抽象。假设还有一个Producer类向这个存储区添加项目，但它在某个点停止，并且只有一个生产者线程和一个消费者线程。
这段代码（至少）有两个问题，但我不确定如何修复它们：

1. Consumer每秒并不消耗n项，因为它在处理n项后会休眠整整一秒（假设n不会太高，以至于处理n项需要超过1秒，但它也不一定很小）。
   1.如果在最后一秒没有n项，Consumer将尝试消耗太多次。
   在“每秒做n次某件事”的一般情况下，实现这种模式的正确方法是什么？