Asio - requete asynchrone, question

Hello,

Je suis attentiovement le travail qu'a fait Gwenael Dunand (http://gwenael-dunand.developpez.com...cpp/boost/asio). par contre, une question concernant les times asynchrone.

Pour moi, ce que cela signifie, c'est qu'on puisse faire qqch pendant que ca travaille, et que cela ne bloquera pas le script... Mais si je fais ce test:

Code:

---

1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20

#include <iostream> #include <boost/asio.hpp> #include <boost/date_time/posix_time/posix_time.hpp>   void print(const boost::system::error_code& /*error*/) // (3) { std::cout << "Terminé !" << std::endl; // (4) }   int main() { boost::asio::io_service io;   boost::asio::deadline_timer t(io, boost::posix_time::seconds(5)); // (1) t.async_wait(print); // Attente asynchrone (2)   io.run(); std::cout << "En cours !" << std::endl; // (4) return 0; }

---

Pour moi, cela devrait m'afficher

Code:

---

1 2	En cours ! Terminé !

---

Or cela m'affiche

Code:

---

1 2	Terminé ! En cours !

---

Donc, une fois le io.run() lancé, il attends bien qu'il soit terminé, et ne poursuit pas le programme... je ne vois aucunes différences, du coup, avec le t.wait du précédent exemple...

Y a qqch que je ne comprends pas? Ou fait faux?

merci.
Onet

Salut,

io_service::run() est bloquant, donc l'affichage du programme est normal.
Si tu veux que ça ne soit pas bloquant, il faut le lancer dans un thread, comme je l'avais suggérer dans l'article.
Ce qui nous donne :

Code:

---

1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26

#include <iostream> #include <boost/asio.hpp> #include <boost/date_time/posix_time/posix_time.hpp> #include <boost/thread.hpp> #include <boost/bind.hpp>   void print(const boost::system::error_code& /*error*/) // (3) { std::cout << "Terminé !" << std::endl; // (4) }   int main() { boost::asio::io_service io;   boost::asio::deadline_timer t(io, boost::posix_time::seconds(5)); // (1) t.async_wait(print); // Attente asynchrone (2)   boost::thread my_thread(boost::bind(&boost::asio::io_service::run, boost::ref(io) ) ); std::cout << "En cours !" << std::endl; // (4)   // On fait une pause sinon ça va quitter !!! system("pause"); return 0; }

---

Et le tour est joué ! ;)

Ok, donc je suis obligé de passer par un thread...

Bon, ben je vais continuer dans ce sens, merci de ta réponse. Je vais certainement revenir, au vu du prog que je dois préparer ;)

Onet

petit souci rapide, si tu as 2s:

J'ai tenté ton code, mais j'obtiens:

Code:

---

1 2	no matching function for call to ‘boost::thread::thread(<unresolved overloaded function type>, const boost::reference_wrapper<boost::asio::io_service>)’

---

Avec:

Code:

---

1 2 3 4 5 6 7 8 9 10

Building file: ../src/test_socket.cpp Invoking: GCC C++ Compiler g++ -O0 -g3 -Wall -c -fmessage-length=0 -MMD -MP -MF"src/test_socket.d" -MT"src/test_socket.d" -o"src/test_socket.o" "../src/test_socket.cpp" ../src/test_socket.cpp: In function ‘int main()’: ../src/test_socket.cpp:20: erreur: no matching function for call to ‘boost::thread::thread(<unresolved overloaded function type>, const boost::reference_wrapper<boost::asio::io_service>)’ /usr/local/include/boost/thread/detail/thread.hpp:199: note: candidats sont: boost::thread::thread(boost::detail::thread_move_t<boost::thread>) /usr/local/include/boost/thread/detail/thread.hpp:147: note: boost::thread::thread() /usr/local/include/boost/thread/detail/thread.hpp:118: note: boost::thread::thread(boost::detail::thread_data_ptr) /usr/local/include/boost/thread/detail/thread.hpp:108: note: boost::thread::thread(boost::thread&) make: *** [src/test_socket.o] Erreur 1

---

Une idée? merci

Onet

Zut j'avais oublié le boost::bind.

Ca marchera mieux comme ça :

Code:

---

boost::thread my_thread(boost::bind(&boost::asio::io_service::run, boost::ref(io) ) );

---

Yep,

tip top, merci. Ca me donne une bonne base pour ce que j'ai a faire. Je reviendrais surement a toi, sur un autre thread :p. Pars pas en vacance tout de suite ;)

Onet

De rien ! ;)

Citation:

---

Envoyé par onet

Pars pas en vacance tout de suite ;)

---

C'est pas vraiment prévu ! :aie:

Parfait ;) lol!

Bon, j'y retourne, j'ai un serveur/client en tcp-IP non bloquant pour Linux a faire, lol!

Onet