Discussion :

[guillaume07]

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.

[Mat007]

Salut,

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

Oui.

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.

[poukill]

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é ...

[Mat007]

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.

[guillaume07]

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

ça veut dire qu'on peut appelé io.run() plusieurs fois pour la meme socket ??

[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.

[Arzar]

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

Code :

Sélectionner tout - Visualiser dans une fenêtre à part

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 :

Sélectionner tout - Visualiser dans une fenêtre à part

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));

[guillaume07]

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

Code :

Sélectionner tout - Visualiser dans une fenêtre à part

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 :

Sélectionner tout - Visualiser dans une fenêtre à part

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 ?