soluzione ottima per la memorizzazione di dati in XML thread-safe con Boost

Question

PROBLEMA:

Sto sviluppando un server con Boost e non v'è un file XML da cui alcuni dati vengono caricati dal thread principale in fase di inizializzazione .

Durante l'esecuzione possono verificarsi alcune modifiche che devono essere memorizzate nel file xml. A questo scopo un negozio di funzione() è stato realizzato in una classe chiamata database:

Database::store() 
{ 
    boost::mutex::scoped_lock lock(_databaseMutex); 
    //xml file wirting 
} 

Se voglio archiviare le modifiche da un altro thread diversa dalla principale che ha creato il database di classe (una connessione socket, ad esempio), xml ha esito negativo in quanto sembra essere thread non sicuro. soluzione

Posible:

La mia idea è quella di creare un ciclo nel (thread principale) del server in attesa di notifiche da altri thread, qualcosa di simile:

void loopQueue() 
{ 
    boost::mutex::scoped_lock lock(_queueMutex);  // close the lock  
    while(true) 
    { 
     while (_queuedActions.empty()) 
     { 
      _updateAvailable.wait(lock); 
     }   
     getDatabase(param)->store();  //stores database 
     _queuedActions.pop(); 
    } 
} 

In questo modo la scrittura xml fa non andare in crash.

Domanda:

• Esiste una soluzione più efficiente o migliore per questo tipo di problema o è questo il modo giusto?

Answer 1

Tutto dipende da cosa sta facendo il thread principale e da come il programma è progettato e implementato.

La soluzione proposta funzionerà correttamente ma esegue il hog di un singolo thread solo per l'elaborazione delle scritture nel file xml.

Hai familiarità con boost::asio?

In qualsiasi server vorrei utilizzare boost::asio con un singolo thread o un pool di thread chiamando ioservice::run. Gli aggiornamenti al file xml vengono "postati" al ciclo di eventi asio e vengono inviati/eseguiti da uno qualsiasi dei thread worker nel suo threadpool (ovvero i thread che hanno chiamato ioserive :: run). Ciò significa che il sistema utilizza meno thread e i thread che sta utilizzando sono in grado di eseguire numerose operazioni asincrone.

Nota: boost::asio::post è usato per avere una funzione chiamata all'interno del ciclo di eventi ASIO, questo consente di controllare/serializzare l'accesso al file xml

See: boost::asio boost::asio::post