mirror of
https://github.com/clash-verge-rev/clash-verge-rev.git
synced 2026-04-18 16:30:32 +08:00
fix(timer): improve delay timer handling during task execution
This commit is contained in:
parent
add2c1036b
commit
4ee6402e29
@ -126,11 +126,11 @@ impl Timer {
|
|||||||
profiles_to_update.len()
|
profiles_to_update.len()
|
||||||
);
|
);
|
||||||
let timer_map = self.timer_map.read();
|
let timer_map = self.timer_map.read();
|
||||||
let delay_timer = self.delay_timer.write();
|
|
||||||
|
|
||||||
for uid in profiles_to_update {
|
for uid in profiles_to_update {
|
||||||
if let Some(task) = timer_map.get(&uid) {
|
if let Some(task) = timer_map.get(&uid) {
|
||||||
logging!(info, Type::Timer, "立即执行任务: uid={}", uid);
|
logging!(info, Type::Timer, "立即执行任务: uid={}", uid);
|
||||||
|
let delay_timer = self.delay_timer.write();
|
||||||
if let Err(e) = delay_timer.advance_task(task.task_id) {
|
if let Err(e) = delay_timer.advance_task(task.task_id) {
|
||||||
logging!(warn, Type::Timer, "Failed to advance task {}: {}", uid, e);
|
logging!(warn, Type::Timer, "Failed to advance task {}: {}", uid, e);
|
||||||
}
|
}
|
||||||
|
|||||||
Loading…
x
Reference in New Issue
Block a user