C++'da destek kullanarak bir iş parçacığı havuzu nasıl oluşturur ve görevleri iş parçacığına nasıl atayabilirim?C++'da destek kullanarak iş parçacığı havuzu nasıl oluşturulur?
cevap
İşlem oldukça basit. Önce bir asio :: io_service ve thread_group oluşturun. Thread_group io_service'ye bağlanmış iş parçacıkları ile doldurun. boost::bind işlevini kullanarak iş parçacıklarına görev atayın.
İpliklerini durdurmak için (genellikle programınızdan çıkarken) io_service'i durdurun ve tüm konulara katılın.
yalnızca bu başlıklara gerek olmalıdır: Burada
#include <boost/asio/io_service.hpp>
#include <boost/bind.hpp>
#include <boost/thread/thread.hpp>
bir örnek:
/*
* Create an asio::io_service and a thread_group (through pool in essence)
*/
boost::asio::io_service ioService;
boost::thread_group threadpool;
/*
* This will start the ioService processing loop. All tasks
* assigned with ioService.post() will start executing.
*/
boost::asio::io_service::work work(ioService);
/*
* This will add 2 threads to the thread pool. (You could just put it in a for loop)
*/
threadpool.create_thread(
boost::bind(&boost::asio::io_service::run, &ioService)
);
threadpool.create_thread(
boost::bind(&boost::asio::io_service::run, &ioService)
);
/*
* This will assign tasks to the thread pool.
* More about boost::bind: "http://www.boost.org/doc/libs/1_54_0/libs/bind/bind.html#with_functions"
*/
ioService.post(boost::bind(myTask, "Hello World!"));
ioService.post(boost::bind(clearCache, "./cache"));
ioService.post(boost::bind(getSocialUpdates, "twitter,gmail,facebook,tumblr,reddit"));
/*
* This will stop the ioService processing loop. Any tasks
* you add behind this point will not execute.
*/
ioService.stop();
/*
* Will wait till all the threads in the thread pool are finished with
* their assigned tasks and 'join' them. Just assume the threads inside
* the threadpool will be destroyed by this method.
*/
threadpool.join_all();
Kaynak: Recipes < Asio
['boost :: asio :: io_service :: work'] (http://www.boost.org/doc/libs/1_54_0/doc/html/boost_asio/reference/io_service__work.html) nesnesi kritik bir parçadır Bunu düzgün çalışması için Ayrıca ['io_service :: stop()'] (http://www.boost.org/doc/libs/1_54_0/doc/html/boost_asio/reference/io_service/stop.html) herhangi bir ek görevin yürütülmesini engelleyecektir. Görevin io_service'de ne zaman yayınlandığına bakılmaksızın. Örneğin, getSocialUpdates(), 'stop()' dan önce "io_service" kuyruğuna eklenirken, stop() işlevi çağrıldığında orta yürütme değilse, sıraya girer. –
"work" nesnesini * oluşturmanız gerekir * önce iş parçacığı oluşturursunuz, aksi takdirde bir şey yapmadan hemen sonlandırılabilirler. – Miral
@TannerSansbury Aslında bu reçete beni çok kafa karıştırıcı yapıyor, çünkü io_service.stop() 'dan sonra tüm bitmemiş işlerim öldürülüyor. Uygun bir yol ioservice.stop() öğesini kaldırmalı, ancak iş nesnesini yok etmeli, sonra tüm işlerin bitmesini sağlamak için threadpool.join_all() öğesini çağırın. – CyberSnoopy
Sana kodu sevdiğini biliyorum. Kanunun
Benim Versiyon
namespace bamthread
{
typedef std::unique_ptr<boost::asio::io_service::work> asio_worker;
struct ThreadPool {
ThreadPool(size_t threads) :service(), working(new asio_worker::element_type(service)) {
while(threads--)
{
auto worker = boost::bind(&boost::asio::io_service::run, &(this->service));
g.add_thread(new boost::thread(worker));
}
}
template<class F>
void enqueue(F f){
service.post(f);
}
~ThreadPool() {
working.reset(); //allow run() to exit
g.join_all();
service.stop();
}
private:
boost::asio::io_service service; //< the io_service we are wrapping
asio_worker working;
boost::thread_group g; //< need to keep track of threads so we can join them
};
}
Piece Kullanılır:
{
bamthread::ThreadPool tp(n_threads);
BOOST_FOREACH(int y, boost::irange(starty, endy, step)){
int im_x = 0;
BOOST_FOREACH(int x, boost::irange(startx, endx, step)){
tp.enqueue (boost::bind(&camera_view_depth::threaded_intersection, this,
intersections,
intersected,
im_x,
im_y,
_faces, x, y));
++im_x;
}
++im_y;
}
}
- 1. Windows iş parçacığı havuzu ve CLR iş parçacığı havuzu
- 2. Takviye kullanarak bir iş parçacığı havuzu oluşturma
- 3. İş parçacığı havuzu 'yinelenen' görevler
- 4. İş parçacığı havuzu yeniden boyutlandırılıyor
- 5. Android'de iş parçacığı havuzu boyutu nasıl seçilir?
- 6. İş parçacığı güvenli ContentProvider nasıl oluşturulur?
- 7. İş parçacığı güvenli GetEventHandler() nasıl oluşturulur?
- 8. System.Timers.Timer iş parçacığı bir iş parçacığı havuzu üzerinde yürütme için nasıl engellenir?
- 9. Sonsuz döngü işlevini yapmak için iş parçacığı havuzu nasıl kullanılır?
- 10. İskele parçacığı havuzu embeddend
- 11. QtCon ile ilişkili üye işlevi ve iş parçacığı havuzu
- 12. Yükseltme :: asio iş parçacığı havuzu genel amaçlı görevler için kullan
- 13. Tomcat iş parçacığı havuzu? Tomcat.conf'da yorumladı, kullanmalı mıyım?
- 14. arka plan iş parçacığı kullanarak Task.Run
- 15. Tek bir iş parçacığı kullanarak çoklu iş parçacığını nasıl gerçekleştirirsiniz?
- 16. Bazı nanosaniye için bir destek iş parçacığı uyuyor
- 17. Dostum, iş parçam nerede? (veya: bir .NET iş parçacığı havuzu iş parçacığı yeniden adlandırın - bu mümkün mü?)
- 18. iş parçacığı
- 19. iş parçacığı içinde yerel depolama iş parçacığı
- 20. İş parçacığı tanıtıcısı iş parçacığı tanıtıcısı
- 21. Tomcat iş parçacığı havuzundaki iş parçacığı sayısı nasıl artırılır?
- 22. java parçacığı havuzu görev aşımı sorunu
- 23. iş parçacığı yerel kaldırma yöntemi
- 24. Yürütücüler hizmetini kullanarak Java'da sabit boyutlu bir iş parçacığı havuzu oluşturmanın en iyi yolu
- 25. Trafik ışığı semaphore iş parçacığı kullanarak
- 26. Maksimum iş parçacığı sorunu
- 27. Çoklu iş parçacığı nasıl ekleyebilirim?
- 28. İş parçacığı engellenmeden bekleyin. - Nasıl?
- 29. Django/sqlite3 "OperationalError: iş parçacığı yok" iş parçacığı üzerinde
- 30. UI iş parçacığı üzerinde görev sürdürme, arka plan iş parçacığı
([boost kullanılarak bir iş parçacığı havuzu oluşturma] olası yinelenen http://stackoverflow.com/ sorular/4084777/oluşturma-bir-havuz-kullanarak-boost) –
Sadece bir şey, diğer soruya cevap vermeme izin vermez ve kendi kendine cevap verilir ve teşvik edilir. –
[Diğer soru] için bir yanıt gönderebilmeniz gerekir (http://stackoverflow.com/questions/4084777/creating-a-thread-pool-using-boost), kapalı değil veya [korumalı] (http://meta.stackexchange.com/questions/52764/what-is-a-protected-question). –