Rust循环中实现每秒执行函数的代码异常问题咨询

问题背景 #

需要在Rust的无限循环里每秒执行一次dostuff()，同时循环还要处理其他执行频率更高的操作（因此不能用sleep阻塞整个循环），但两段测试代码都达不到预期效果。

错误代码分析 #

第一段代码：完全不执行dostuff() #

use std::time::{Instant, Duration};

fn main() {
    let mut lastsec = Instant::now();

    loop {
        if Instant::now() - lastsec >= Duration::from_secs(1) {
            dostuff();
            lastsec = Instant::now();
        }
    }
}

fn dostuff() {
    println!("Performing action...");
}

异常原因：
这段代码的循环没有任何额外操作，CPU会以极限速度迭代循环。编译器会做激进优化，把lastsec = Instant::now()的操作和判断时的Instant::now()绑定，导致两者的差值永远为0，永远满足不了>=1秒的条件，自然不会执行dostuff()。就算没有编译器优化，循环跑的速度远快于1秒间隔，刚更新完lastsec就进入下一次判断，时间差也永远凑不够1秒。

第二段代码：1秒后持续高频执行dostuff() #

use std::time::{Instant, Duration};

fn main() {
    let mut lastsec = Instant::now();

    loop {
        if Instant::now() - lastsec >= Duration::from_secs(1) {
            dostuff();
        }
    }
}

fn dostuff() {
    println!("Performing action...");
}

异常原因：
当第一次满足时间差>=1秒的条件后，lastsec再也没被更新，之后每一次循环迭代都会触发判断条件。循环本身没有任何延迟，会把CPU拉满疯狂调用dostuff()，相当于1秒内执行几百万次，完全不符合每秒一次的要求。

正确实现方案 #

要实现每秒执行一次dostuff()，同时不耽误高频操作，需要做到两点：避免编译器过度优化、准确控制下次执行的时间点，还要降低CPU空转的占用。

use std::time::{Instant, Duration};
use std::thread;

fn main() {
    let mut next_run = Instant::now();

    loop {
        // 先处理你的高频操作
        handle_high_freq_tasks();

        if Instant::now() >= next_run {
            dostuff();
            // 直接在原时间上加1秒，避免dostuff的执行耗时导致频率漂移
            next_run += Duration::from_secs(1);
        }

        // 加个微秒级延迟，降低CPU占用，同时阻止编译器优化
        thread::sleep(Duration::from_micros(100));
    }
}

fn dostuff() {
    println!("Performing action...");
}

fn handle_high_freq_tasks() {
    // 这里写你的高频操作逻辑
}

关键细节：

• 用next_run记录下次执行的时间点，每次执行完直接加1秒，不管dostuff()跑多久，都能保证固定的执行间隔，不会出现漂移
• 加入100微秒的短延迟，既不会影响高频操作的处理速度，又能大幅降低CPU占用，同时避免编译器对循环做过度优化
• 高频操作放在时间判断前面，确保优先处理高频任务

内容的提问来源于stack exchange，提问作者Proof of Concept