Segundo essa resposta a biblioteca padrão do C++11 não presta suporte padrão para o controle de prioridade de threads. (O autor ainda acredita que não isso não mudará no C++14)
Nessa mesma resposta ele cita um comando que funciona em sistemas que sigam as normas POSIX:
pthread_setschedparam(thread.native_handle(), politica, {prioridade});
Como você quer só para linux, esse método deve resolver seu problema. Existem ainda alguns pontos relevantes a serem levados em conta.
A política padrão de threads do Linux tem prioridade dinâmica
Geralmente, quando você inicia uma thread, o Linux coloca a política SCHED_OTHER
, como é visto nessa resposta da SOEN.
Nessa mesma resposta, ele coloca os tipos de política que podem ser adotadas para o sistema de thread e qual a prioridade mínima e a máxima:
SCHED_FIFO
: Esquema de fila, primeira a entrar, é o primeiro a sair. (1/99)
SCHED_RR
: Esquema de política round-robin. (1/99)
Onde a prioridade está da seguinte forma (min/máx). Eu optei por colocar as políticas que tinha prioridade. Apesar de eu ler nos comentários que o SCHED_OTHER
pode oferecer um certo nível de controle de prioridade, ele é definido pelo próprio sistema conforme o comportamento da thread, o que você pode fazer é dar "uma dica da importância da thread", setando sua prioridade como muito alta (-20) ou muito baixa (19).
Políticas para troca de threads
Threads com as políticas SCHED_RR
ou SCHED_FIFO
serão trocadas se um dos dois eventos acontecerem, ainda segundo esse link:
- Uma thread é posta para dormir (
sleep
) ou passa a esperar um evento
- Uma thread de tempo real de prioridade maior está pronta para rodar
Esses pontos devem ser levados em conta quando você for implementar as suas threads.
Dito isso, vamos ao nosso exemplo:
Exemplo retirado do cpp reference:
#include <thread>
#include <mutex>
#include <iostream>
#include <chrono>
#include <cstring>
#include <pthread.h>
std::mutex iomutex;
void f(int num) {
std::this_thread::sleep_for(std::chrono::seconds(1));
sched_param sch;
int policy;
pthread_getschedparam(pthread_self(), &policy, &sch);
std::lock_guard<std::mutex> lk(iomutex);
std::cout << "Thread " << num << " esta executando com prioridade "
<< sch.sched_priority << '\n';
}
int main(){
//A thread 2 será uma thread padrão
std::thread t1(f, 1), t2(f, 2);
sched_param sch;
int policy;
pthread_getschedparam(t1.native_handle(), &policy, &sch);
sch.sched_priority = 20;
//Nessa linha ele seta a política e a prioridade da thread 1
if(pthread_setschedparam(t1.native_handle(), SCHED_FIFO, &sch)) {
std::cout << "Falha para utilizar setschedparam: " << std::strerror(errno) << '\n';
}
t1.join(); t2.join();
}
Apesar de tudo, eu fiquei com uma dúvida, talvez pelo meu desconhecimento de como sistemas POSIX tratam as prioridades de threads, mas, pelo que o exemplo coloca como saída, threads com valores mais altos de prioridade, tem prioridade menor.
Saída do exemplo:
Thread 2 esta executando com prioridade 0
Thread 1 esta executando com prioridade 20