Merhaba yaz\u0131l\u0131mperver dostlar\u0131m. Bu yaz\u0131m ile birlikte art\u0131k elimizi kirletiyor ve boost k\u00fct\u00fcphanesini adam ak\u0131ll\u0131 kullanmaya ba\u015fl\u0131yoruz. Buna da, asio kabiliyetler ile birlikte olduk\u00e7a s\u0131k kullan\u0131lan bind’a h\u0131zl\u0131ca bakarak ba\u015fl\u0131yor olaca\u011f\u0131z. Sonra da, io_context s\u0131n\u0131f\u0131na bakaca\u011f\u0131z. \u00d6nceki boost yaz\u0131lar\u0131m i\u00e7in a\u015fa\u011f\u0131daki ba\u011flant\u0131lar\u0131ma g\u00f6z atabilirsiniz:<\/p>\n
Haftal\u0131k C++ 54 – Boost.Asio I – Giri\u015f<\/a><\/strong><\/span><\/p>\n Haftal\u0131k C++ 55 – Boost Asio II – Temeller ve Mimari<\/a><\/strong><\/span><\/p>\n boost::bind, k\u0131saca, farkl\u0131 arg\u00fcman tiplerini alan, fonksiyonlara ge\u00e7iren ve bunun s\u0131ralamas\u0131 konusunda da kolayl\u0131k sa\u011flayan bir mekanizma sunmakta. Peki sadece fonksiyon mu? Hay\u0131r, tekil fonksiyon, s\u0131n\u0131f metotlar\u0131, fonksiyon nesneleri, fonksiyon i\u015faret\u00e7ilerini de bu ba\u011flamda kullanabileceksiniz.<\/p>\n boost::bind, asl\u0131nda daha \u00f6nce std::bind1st() ve std::binds2nd() fonksiyonlar\u0131 ile sunulan bir tak\u0131m \u00f6zellikleri daha basitle\u015ftiren ve genelle\u015ftiren bir kullan\u0131m sunmaktad\u0131r. Bu arada, bu iki kabiliyet, C++98 ile birlikte gelmi\u015f, boost.bind bunlar\u0131 daha kolay kullan\u0131lmas\u0131na sa\u011flayan bir mekanizma sunmakta, zaten C++ 11 ile birlikte std::bind da <functional> ba\u015fl\u0131k dosyas\u0131 ile dahil edilmi\u015f durumda (bu yaz\u0131da bunlar\u0131n farklar\u0131na girmeyece\u011fim ama bire bir ayn\u0131 olmasa da farklar mevcut, merakl\u0131lar\u0131 std::bind vs boost::bind<\/a><\/span><\/strong> sonu\u00e7lar\u0131na g\u00f6z atabilir).<\/p>\n Hemen bir \u00f6rnek ile konuya atlayal\u0131m:<\/p>\n \u00d6rnek kod san\u0131r\u0131m sizlere, boost::bind’\u0131n kullan\u0131m\u0131na ili\u015fkin bir fikir verecektir. Temelde, verilen farkl\u0131 \u00e7a\u011fr\u0131labilir fonksiyon, fonksiyon nesnelerine girdileri jenerik bir \u015fekilde iletilebildi\u011fini g\u00f6rebileceksiniz.<\/p>\n Yukar\u0131daki kullan\u0131m yan\u0131nda, std::function benzeri, boost::function kullan\u0131m\u0131nda da, boost::bind kullan\u0131labilir.<\/p>\n \u015eimdi biraz asio’ya taraflar\u0131na yakla\u015fabiliriz.<\/p>\n boost::bind’tan sonra art\u0131k asio’nun temel motivasyonu olan asenkron \u00e7a\u011fr\u0131lara g\u00f6z atman\u0131n zaman\u0131 geldi. Bunun da temelinde io_context s\u0131n\u0131f\u0131 bulunmaktad\u0131r (proactor \u00f6r\u00fcnt\u00fcs\u00fc ger\u00e7ekleyen). \u0130nternet \u00fczerindeki \u00f6rneklerde, boost::asio::io_service s\u0131n\u0131f\u0131n\u0131n da kullan\u0131ld\u0131\u011f\u0131n\u0131 g\u00f6rebilirsiniz ama yeni boost s\u00fcr\u00fcmleri ile birlikte io_context s\u0131n\u0131f\u0131n\u0131n kullan\u0131lmas\u0131 tavsiye edilmektedir. Bu s\u0131n\u0131f k\u0131saca, i\u015fletim sisteminin sundu\u011fu I\/O alt yap\u0131lar\u0131n\u0131 soyutlayarak, kendisine atanan i\u015fi asenkron (veya istenen \u015fekilde) ger\u00e7ekle\u015ftirilmesi i\u00e7in gerekli fonksiyonaliteyi sunar. \u00c7e\u015fitli kaynaklarda “executor” olarak da kullan\u0131labiliyor.<\/p>\n Bu nesneye (io_context) \u00f6\u011frenece\u011fimiz ilk API\u00a0 Di\u011fer ya\u015fam d\u00f6ng\u00fcs\u00fc API’leri i\u00e7in https:\/\/www.boost.org\/doc\/libs\/1_81_0\/doc\/html\/boost_asio\/reference\/io_context.html<\/a><\/strong><\/span> sayfas\u0131na g\u00f6z atabilirsiniz. Burada h\u0131zl\u0131ca poll() API’sinden de bahsedebilirim. run()’dan farkl\u0131 olarak, bu API uygulamay\u0131 bekletmeden sadece haz\u0131r kotar\u0131c\u0131lar\u0131\/i\u015flerin i\u015flenmesini sa\u011flar. Ayr\u0131ca, run ve poll API’lerinin tek i\u015flemi eritmeye y\u00f6nelik API’leri de bulunmaktad\u0131r. Bunlar\u0131 uygulaman\u0131z\u0131n ihtiyac\u0131na g\u00f6re kullanabilirsiniz.<\/p>\n Bir di\u011fer s\u0131n\u0131f ise executor_work_guard<\/em> (eski s\u00fcr\u00fcmlerde work olarak da kullan\u0131l\u0131yordu). Bu s\u0131n\u0131f\u0131n k\u0131saca g\u00f6revi de, io_context’in run() API’sini \u00e7a\u011f\u0131rd\u0131ktan sonra, i\u015f kalmay\u0131nca d\u00f6nmeyip devam etmesini sa\u011flar. Bu kullan\u0131mda, durdurmak i\u00e7in ise, io_context::stop() API’sini ya da, executor_work_guard’<\/em>un reset() API’sini kullanabilirsiniz. A\u015fa\u011f\u0131da da buna ili\u015fkin \u015fablon bir kod bulabilirsiniz:<\/p>\n Evet, ilgili io_context s\u0131n\u0131f\u0131n\u0131 olu\u015fturduk, ba\u015flatt\u0131k ya da durdurduk. \u015eimdi s\u0131ra geldi, bu s\u0131n\u0131f\u0131 kullanarak asenkron i\u015fleri yapt\u0131rmaya.<\/p>\n Bu ama\u00e7la kullanabilece\u011fimiz temel iki API bulunmaktad\u0131r. Bunlar, Tahmin edebilece\u011finiz, \u00fczere bu iki API yan\u0131nda bir \u00e7ok di\u011fer API’de bulunmakta fakat temel i\u015flevleri g\u00f6stermek ve kullanmak ad\u0131na bunlar\u0131n yeterli olaca\u011f\u0131 kan\u0131s\u0131nday\u0131m.<\/p>\n Vermi\u015f oldu\u011fumuz bu i\u015fler bitene kadar daha \u00f6nce bahsetti\u011fim run() API’si d\u00f6n\u00fc\u015f yapm\u0131yor olacak ve b\u00fct\u00fcn bu i\u015flerin tamamlanmas\u0131n\u0131 bekliyor olacak.<\/p>\n \u015eimdi bu \u00f6\u011frendiklerimizi, kapsaml\u0131 bir \u00f6rnek (https:\/\/github.com\/yazilimperver\/asio_adventure\/tree\/master\/boost_bind_example<\/a><\/strong><\/span>) ile inceleyelim:<\/p>\n Bu \u00f6rnekteki \u00f6nemli noktalar\u0131, numaraland\u0131rarak \u00fczerinden ge\u00e7iyor olal\u0131m:<\/p>\n Evet sevgili dostlar, kodun da \u00fczerinden ge\u00e7ti\u011fimize g\u00f6re, \u00e7\u0131kt\u0131ya bir g\u00f6z atal\u0131m:<\/p>\n \u00d6ncelikli olarak, dispatch() API’lerinin eritildi\u011fine dikkat edelim. Bu arada, bu ve sonraki yaz\u0131l\u0131lar\u0131m i\u00e7in kullanaca\u011f\u0131m \u00f6rneklere a\u015fa\u011f\u0131daki repo’dan ula\u015fabilirsiniz:<\/p>\n https:\/\/github.com\/yazilimperver\/asio_adventure<\/strong><\/span><\/a><\/p>\n Bir sonraki yaz\u0131mda g\u00f6r\u00fc\u015fmek dile\u011fiyle, bol kodlu g\u00fcnler diliyorum.<\/p>\n","protected":false},"excerpt":{"rendered":" Merhaba yaz\u0131l\u0131mperver dostlar\u0131m. Bu yaz\u0131m ile birlikte art\u0131k elimizi kirletiyor ve boost k\u00fct\u00fcphanesini adam ak\u0131ll\u0131 kullanmaya ba\u015fl\u0131yoruz. Buna da, asio kabiliyetler ile birlikte olduk\u00e7a s\u0131k kullan\u0131lan bind’a h\u0131zl\u0131ca bakarak ba\u015fl\u0131yor olaca\u011f\u0131z. Sonra da, io_context s\u0131n\u0131f\u0131na bakaca\u011f\u0131z. \u00d6nceki boost yaz\u0131lar\u0131m i\u00e7in a\u015fa\u011f\u0131daki ba\u011flant\u0131lar\u0131ma g\u00f6z atabilirsiniz: Haftal\u0131k C++ 54 – Boost.Asio I – Giri\u015f Haftal\u0131k C++ 55… Continue reading boost::bind<\/strong><\/span><\/h2>\n
#include <boost\/bind.hpp>\r\n#include <vector>\r\n#include <algorithm>\r\n#include <iostream>\r\n\r\nvoid PrintSum(std::ostream *os, int i, int j) {\r\n *os << \"Toplam: \" << i + j << '\\n';\r\n}\r\n\r\nclass PrintClass{\r\npublic:\r\n void PrintSum(std::ostream *os, int i, int j) const {\r\n *os << \"Toplam: \" << i + j << '\\n';\r\n }\r\n};\r\n\r\nint main()\r\n{\r\n std::vector<int> v{1, 3, 2};\r\n \/\/ Tek fonksiyon kullanimi\r\n \/\/ Her bir elemana bes ekleyelim\r\n std::for_each(v.begin(), v.end(), boost::bind(PrintSum, &std::cout, _1, 5));\r\n\r\n \/\/ Sinif uyesi fonksiyon kullanimi\r\n \/\/ Her bir elemani kendisi ile toplayalim\r\n PrintClass printObject;\r\n std::for_each(v.begin(), v.end(), boost::bind(&PrintClass::PrintSum, &printObject, &std::cout, _1, _1));\r\n}<\/pre>\n#include <iostream>\r\n#include <boost\/bind.hpp>\r\n#include <boost\/function.hpp>\r\n\r\nvoid PrintDifference(int i, int j) {\r\n\tstd::cout << \"Fark: \" << i - j << '\\n';\r\n}\r\n\r\nint main() {\r\n \/\/ Asagidaki gibi bir kullanim oldugu gibi, yoruma alinan auto'lu satir da kullanilabilir\r\n\tconst boost::function<void(int, int)> fun1 = boost::bind(&PrintDifference, _1, _2);\r\n\t\/\/ const auto fun = boost::bind(&PrintSum, _1, _2);\r\n\r\n \/\/ Arguman sirasi bu noktada onemli\r\n\tfun1(5, 6);\r\n\t\r\n\t\/\/ Arguman sirasinin yerini degistirebilirsiniz\r\n\tconst auto fun2 = boost::bind(&PrintDifference, _2, _1);\r\n\tfun2(5, 6);\r\n\t\r\n\t\/\/ Beklenenden fazla girilen argumanlar da goz ardi edilmektedir\r\n\tfun2(8, 3, 2, 5, 6, 1, 7);\r\n\t\r\n\treturn 0;\r\n}<\/pre>\nboost::asio::io_context<\/strong><\/span><\/h2>\n
run()<\/code>‘d\u0131r. Bu API ile, io_context’in olay i\u015fleme d\u00f6ng\u00fcs\u00fcn\u00fc ba\u015flat\u0131yoruz. Bu d\u00f6ng\u00fc, i\u015flenecek herhangi bir i\u015f kalmayana kadar ya da ilgili io_context nesnesi durdurulana kadar, \u00e7al\u0131\u015ft\u0131r\u0131ld\u0131\u011f\u0131 thread’i bloklar. Burada bir di\u011fer g\u00fczel \u00f6zellik (hatta \u00f6l\u00e7eklendirmek isteyece\u011finiz uygulamalar\u0131n\u0131zda ihtiya\u00e7 da duyaca\u011f\u0131n\u0131z) de, bu nesnenin run() API’sini farkl\u0131 threadlerden de \u00e7a\u011f\u0131rabilece\u011finizdir. Bu sayede, bir nevi thread havuzu da olu\u015fturmu\u015f oluyoruz. Bir di\u011fer ifade ile, verdi\u011finiz i\u015fleri eritecek birden fazla thread olmu\u015f oluyor. \u0130lave bir girdi veya kontrol yapmad\u0131\u011f\u0131n\u0131z m\u00fcddet\u00e7e hangi threadin bu ama\u00e7la kullan\u0131laca\u011f\u0131n\u0131 bilemiyoruz (gerek de olmayacak \u015fekilde uygulamalar\u0131m\u0131z\u0131 tasarlayabiliriz). Bunun yan\u0131nda, run() (ve benzeri run_one, run_until, vb.) API’lerini ayn\u0131 thread’ten birden fazla kez \u00e7a\u011f\u0131rmamal\u0131y\u0131z. A\u015fa\u011f\u0131da, kullan\u0131ma ili\u015fkin temel bir \u015fablon bulabilirsiniz:<\/p>\nboost::asio::io_context io_context;\r\n...\r\nfor (;;) {\r\n try {\r\n io_context.run();\r\n break;\r\n }\r\n catch (my_exception& e) {\r\n \/\/ Varsa hatalar, onlar ile ilgilenelim\r\n }\r\n}<\/pre>\nboost::asio::io_context io_context;\r\nboost::asio::executor_work_guard<boost::asio::io_context::executor_type>\r\n = boost::asio::make_work_guard(io_context);\r\n...\r\nwork.reset();<\/pre>\n
post()<\/code> vedispatch()<\/code> API’leridir.<\/p>\n\n
post():<\/code> Verilen i\u015fi kuyru\u011fa koyup, io_context nesnesi taraf\u0131ndan, ilgili thread i\u00e7erisinde ko\u015fturulmas\u0131 (yani \u00e7a\u011fr\u0131lan thread’ten de\u011fil) i\u00e7in kullan\u0131lan API’dir,<\/li>\ndispatch():<\/code>Bir \u00f6nceki API’den farkl\u0131 olarak, io_context’in hemen ilgili i\u015fi ko\u015fturmas\u0131 ve bunu da run(), poll() ya da benzeri API’lerin \u00e7a\u011fr\u0131ld\u0131\u011f\u0131 threadten yapmas\u0131 i\u00e7in kullan\u0131lan API’dir ve kuyru\u011fa koymaz.<\/li>\n<\/ul>\nboost::mutex global_stream_lock;\r\n\r\n\/\/ Bu ornek icin tek bir thread olusturuyoruz\r\nvoid WorkerThread(boost::shared_ptr<boost::asio::io_context> ioctx) {\r\n global_stream_lock.lock();\r\n std::cout << \"Thread Basladi.\" << \" Thread: \" << boost::lexical_cast<std::string>(boost::this_thread::get_id()) << \"\\n\";\r\n global_stream_lock.unlock();\r\n\r\n ioctx->run();\r\n\r\n global_stream_lock.lock();\r\n std::cout << \"Thread Bitti.\\n\";\r\n global_stream_lock.unlock();\r\n}\r\n\r\n\/\/ dispatch() API'si icin kullanilacak\r\n\/\/ Cagiran thread icerisinde cagriliyor ve hemen cagrilir\r\n\/\/ Bu sebeple ilk olarak bu fonksiyonlar \u00e7a\u011fr\u0131l\u0131yor olacaklar.\r\nvoid Dispatch(int i) {\r\n global_stream_lock.lock();\r\n std::cout << \"dispath() fonksiyonu => i = \" << i << std::endl;\r\n global_stream_lock.unlock();\r\n}\r\n\r\n\/\/ post() API'si icin kullanilacak\r\n\/\/ Context'in threadi icerisinde cagriliyor ve her zaman kuyruga eklenir\r\nvoid Post(int i) {\r\n global_stream_lock.lock();\r\n std::cout << \"post() fonksiyonu => i = \" << i << std::endl;\r\n global_stream_lock.unlock();\r\n}\r\n\r\n\/\/ 5'er adet, iki farkli API araciligi ile is verelim\r\nvoid Running(boost::shared_ptr<boost::asio::io_context> ioctx) {\r\n for (int x = 0; x < 5; ++x ) {\r\n \/\/ Iste burada boost::bind ile ilgili fonksiyonlara, dongu numarasini geciriyoruz\r\n ioctx->dispatch(boost::bind(&Dispatch, x));\r\n ioctx->post(boost::bind(&Post, x));\r\n boost::this_thread::sleep(boost::posix_time::milliseconds(1000));\r\n }\r\n}\r\n\r\nint main(void) {\r\n \/\/ 0 - Temel io_context sinifimizi olusturalim\r\n boost::shared_ptr<boost::asio::io_context> io_ctx(new boost::asio::io_context);\r\n boost::asio::executor_work_guard<boost::asio::io_context::executor_type> worker = boost::asio::make_work_guard(*io_ctx.get());\r\n\r\n global_stream_lock.lock();\r\n std::cout << \"Butun isler bittigi zaman uygulama sonlanacaktir.\" << std::endl;\r\n global_stream_lock.unlock();\r\n\r\n boost::thread_group threads;\r\n \r\n \/\/ Burada, boost::bind'i bir threade, thread fonksiyonunu gecirmek icin kullaniyoruz\r\n threads.create_thread(boost::bind(&WorkerThread, io_ctx));\r\n\r\n \/\/ Burada da, asio'ya bir is veriyor ve context nesnesini geciriyoruz\r\n io_ctx->post(boost::bind(&Running, io_ctx));\r\n\r\n worker.reset();\r\n threads.join_all();\r\n\r\n global_stream_lock.lock();\r\n std::cout << \"Butun isler tamamlandi!\" << std::endl;\r\n global_stream_lock.unlock();\r\n\r\n return 0;\r\n}<\/pre>\n\n
\u276f .\/boost_bind_example\r\nButun isler bittigi zaman uygulama sonlanacaktir.\r\nThread Basladi. Thread: 7f839925c700\r\ndispath() fonksiyonu => i = 0\r\ndispath() fonksiyonu => i = 1\r\ndispath() fonksiyonu => i = 2\r\ndispath() fonksiyonu => i = 3\r\ndispath() fonksiyonu => i = 4\r\npost() fonksiyonu => i = 0\r\npost() fonksiyonu => i = 1\r\npost() fonksiyonu => i = 2\r\npost() fonksiyonu => i = 3\r\npost() fonksiyonu => i = 4\r\nThread Bitti.\r\nButun isler tamamlandi!<\/pre>\n