Semplice server multithread in C++?

Question

Voglio scrivere una semplice applicazione server che prenderà i comandi da un'applicazione client ed eseguirà quei comandi in thread separati.

Stavo guardando il server class in dlib. Qualcuno ha esperienza con questo? Come si confronta con l'utilizzo di Asio di Boost?

• Example of server in dlib
• Examples of client/server in Boost Asio

Answer 1

Boost Asio lo farà abbastanza facilmente. Date un'occhiata a the examples in the Highscore tutorial, che mostra come usare Boost per input/output asincroni con multithreading.

#include <boost/asio.hpp> 
#include <boost/thread.hpp> 
#include <iostream> 

void handler1(const boost::system::error_code &ec) 
{ 
    std::cout << "5 s." << std::endl; 
} 

void handler2(const boost::system::error_code &ec) 
{ 
    std::cout << "5 s." << std::endl; 
} 

boost::asio::io_service io_service; 

void run() 
{ 
    io_service.run(); 
} 

int main() 
{ 
    boost::asio::deadline_timer timer1(io_service, boost::posix_time::seconds(5)); 
    timer1.async_wait(handler1); 
    boost::asio::deadline_timer timer2(io_service, boost::posix_time::seconds(5)); 
    timer2.async_wait(handler2); 
    boost::thread thread1(run); 
    boost::thread thread2(run); 
    thread1.join(); 
    thread2.join(); 
} 

Answer 2

vorrei provare e non utilizzare i thread in un primo momento. Vorrei iniziare con libevent. Troverete che il modello libevent è estremamente semplice e scales out way better than spawning a thread per request model. E se libevent non può gestire il tuo caso d'uso c'è sempre Erlang!

Answer 3

L'I/O asincrono è migliore in molti modi rispetto al modello thread-per-client. Le prestazioni ottimali sono effettivamente ottenute da thread-per-core, con ogni thread che esegue l'I/O asincrono.

Nota che il tuo concetto di "server multithread", sebbene non esattamente sbagliato, è molto diverso da quello che tutti gli altri usano per usare quella frase. Generalmente significa un thread per connessione e non la risposta a una connessione parallela attraverso i thread.

L'esempio che si richiede è solo una combinazione di server sincrono a thread singolo + calcolo parallelo.