This commit is contained in:
@@ -7,7 +7,9 @@ use std::sync::atomic::{AtomicI64, AtomicU64};
|
||||
use std::sync::Arc;
|
||||
use std::thread::{self, JoinHandle};
|
||||
use std::time::Duration;
|
||||
use thread_priority::{set_current_thread_priority, ThreadPriority};
|
||||
use thread_priority::ThreadPriority;
|
||||
#[cfg(not(unix))]
|
||||
use thread_priority::set_current_thread_priority;
|
||||
|
||||
use super::LinkState;
|
||||
use crate::model::{
|
||||
@@ -1286,7 +1288,25 @@ fn sequencer_loop(
|
||||
) {
|
||||
use std::sync::atomic::Ordering;
|
||||
|
||||
let _ = set_current_thread_priority(ThreadPriority::Max);
|
||||
#[cfg(unix)]
|
||||
{
|
||||
use thread_priority::unix::{
|
||||
set_thread_priority_and_policy, thread_native_id, RealtimeThreadSchedulePolicy,
|
||||
ThreadSchedulePolicy,
|
||||
};
|
||||
|
||||
let policy = ThreadSchedulePolicy::Realtime(RealtimeThreadSchedulePolicy::Fifo);
|
||||
if let Err(e) =
|
||||
set_thread_priority_and_policy(thread_native_id(), ThreadPriority::Max, policy)
|
||||
{
|
||||
eprintln!("Warning: Could not set SCHED_FIFO: {e:?}");
|
||||
}
|
||||
}
|
||||
|
||||
#[cfg(not(unix))]
|
||||
{
|
||||
let _ = set_current_thread_priority(ThreadPriority::Max);
|
||||
}
|
||||
|
||||
let mut seq_state = SequencerState::new(variables, dict, rng, cc_access);
|
||||
|
||||
|
||||
Reference in New Issue
Block a user