boos::asio asynchrone mais io.run() bloquant

Version imprimable

09/12/2010, 10h19
guillaume07

boos::asio asynchrone mais io.run() bloquant

Bonjour,

Jusqu'à présent je me servais des sockets synchrone de boost, j'essaye d'utiliser les socket asynchrones via les fonctions async_(read/write/connect) et io.run()

Là ou je ne comprends plus, c'est que l'intérêt que je voyais dans l'utilisation des socket asynchrones étaient le faite de ne pas avoir à gérer un thread et que cela ne rendait pas pour autant le thread principal de l'application bloquant.

Mais il n'en est rien car le système des socket asynchrone de boost passe par l'appel à io.run() qui lui est bloquant...

Faut-il donc créer un thread dans lequel s'éxécute io.run() pour ne pas rendre son thread principal bloquant ?

AI-je louper une étape/mal compris un concept ?

Merci.
09/12/2010, 11h17
Mat007

Salut,

Citation:

Envoyé par guillaume07

Faut-il donc créer un thread dans lequel s'éxécute io.run() pour ne pas rendre son thread principal bloquant ?

Oui.

Citation:

Envoyé par guillaume07

AI-je louper une étape/mal compris un concept ?

En fait tu peux créer autant de threads que tu veux et les "confier" à Boost.Asio en leur faisant appeler io.run().
Boost.Asio ne crée pas de threads, d'ailleurs comment pourrait-il ? Leur nombre et réglages dépendent tellement de l'utilisation qu'on en fait.

MAT.
09/12/2010, 11h30
poukill

Citation:

Envoyé par Mat007

Boost.Asio ne crée pas de threads, d'ailleurs comment pourrait-il ? Leur nombre et réglages dépendent tellement de l'utilisation qu'on en fait.

Disons que Boost.Asio en crée en interne pour émuler l'asynchronicité ... ;)
09/12/2010, 11h38
Mat007

Citation:

Envoyé par poukill

Disons que Boost.Asio en crée en interne pour émuler l'asynchronicité ... ;)

Oui c'est vrai, en effet, il *peut* en créer en interne dans son implémentation.

Cf. le point dont on parle dans la doc.

MAT.
09/12/2010, 12h33
guillaume07

"Multiple threads may call io_service::run()"

ça veut dire qu'on peut appelé io.run() plusieurs fois pour la meme socket ??
09/12/2010, 13h36
zul

io.run() lance la boucle d'evenement. TU peux lancer la boucle d"evenement sur n threads, et dans ce cas la, asio va dispatcher les differents jobs sur les threads, de maniere automatique. Si tu n'a qu'un seul socket, ce n'est probablement pas tres utile.

+1
De tête c'est qqchose comme ça :
Asio sur un seul thread. (largement suffisant pour une socket)

Code:

1
2
3
4
5
6
7
 
  asio::io_service io_service;
 
  // donner du travail à io_service
   // ...
 
  boost::thread t(&asio::io_service::run, &io_service);

Asio avec un threadpool :

Code:

1
2
3
4
5
6
7
8
 
   asio::io_service io_service;
  //... donner du travail à io_service
  //...
 
  boost::thread_group threads;
  for (std::size_t i = 0; i < my_thread_count; ++i)
    threads.create_thread(boost::bind(&asio::io_service::run, &io_service));

Citation:
Envoyé par Arzar
+1
De tête c'est qqchose comme ça :
Asio sur un seul thread. (largement suffisant pour une socket)
Code:

1 2 3 4 5 6 7 asio::io_service io_service; // donner du travail à io_service // ... boost::thread t(&asio::io_service::run, &io_service);
Asio avec un threadpool :
Code:

1 2 3 4 5 6 7 8 asio::io_service io_service; //... donner du travail à io_service //... boost::thread_group threads; for (std::size_t i = 0; i < my_thread_count; ++i) threads.create_thread(boost::bind(&asio::io_service::run, &io_service));
ok très bien c'est ce que j'avais compris. J'ai par ailleurs essayé cette syntaxe avec un async_timer mais sans succés, le callback du timer ,n'était jamasi appelé soit dois marcher en théorie ?