boost::threadでマルチスレッドってやつを試してみる その２

前の記事では引数なしの関数でスレッドを生成したが、それで事足りるわけはないので、今回は引数付きの関数を渡してスレッドを生成する。ドキュメントによるとboost::bindをつかってできるよっぽいことが書いてあるので、よく考えずbindを使って関数オブジェクトを渡してみる。ソースは次の通り。

1. #include <iostream>
2. #include <fstream>
3. #include <string>
5. #include <cstdlib>
6. #include <ctime>
8. #include <boost/thread.hpp>
9. #include <boost/bind.hpp>
11. using namespace std;
12. using namespace boost;
14. void writeMsg(string str){
15.   time_t clock;
16.   for (int i = 0; i < 100; i++){
17.     time(&clock);
18.     cout << str << ": " << ctime(&clock);
19.     for(int j = 0; j < 10000; j++){
20.       for(int k = 0; k < 10000; k++){
21.         int a = j * k;
22.       }
23.     }
24.   }
25. }
27. int main()
28. {
29.   string thName1="Thread 1";
30.   string thName2="Thread 2";
31.   thread thWriteMsg1(bind(&writeMsg, thName1));
32.   thread thWriteMsg2(bind(&writeMsg, thName2));
34.   time_t clock;
36.   for (int i = 0; i < 100; i++){
37.     time(&clock);
38.     cout << "MAIN: " << ctime(&clock);
39.     for(int j = 0; j < 10000; j++){
40.       for(int k = 0; k < 10000; k++){
41.         int a = j * k;
42.       }
43.     }
44.   }
46.   thWriteMsg1.join();
47.   thWriteMsg2.join();
49.   return EXIT_SUCCESS;
50. }

TestThread2.cppをダウンロード

前回のソースをちょこっと変更して文字列引数をとるようにした。関数側は「引数文字列: 時間」と出力し、メイン関数は相変わらず「MAIN: 時間」と出力する。実際に動かすとこんな感じ。

MAIN: Sun Feb  6 14:46:52 2011

Thread 2: Sun Feb  6 14:46:52 2011

Thread 1: Sun Feb  6 14:46:53 2011

MAIN: Sun Feb  6 14:46:53 2011

Thread 2: Sun Feb  6 14:46:53 2011

Thread 1: Sun Feb  6 14:46:53 2011

Thread 2: Sun Feb  6 14:46:53 2011

MAIN: Sun Feb  6 14:46:53 2011

Thread 1: Sun Feb  6 14:46:54 2011

Thread 2: Sun Feb  6 14:46:54 2011

MAIN: Sun Feb  6 14:46:54 2011

MAIN: Sun Feb  6 14:46:55 2011

MAIN: Sun Feb  6 14:46:55 2011

MAIN: Sun Feb  6 14:46:55 2011

どうやらうまく動いているようだ。

ドキュメントをよく見てみると「Thread Constructor with arguments」というものがいる。それによると、「thread(関数ポインタ, 引数1, 引数2, ...)」としてもOKらしい。というわけで次のようにソースを変更してみた。

1. #include <iostream>
2. #include <fstream>
3. #include <string>
5. #include <cstdlib>
6. #include <ctime>
8. #include <boost/thread.hpp>
10. using namespace std;
11. using namespace boost;
13. void writeMsg(string str){
14.   time_t clock;
15.   for (int i = 0; i < 100; i++){
16.     time(&clock);
17.     cout << str << ": " << ctime(&clock);
18.     for(int j = 0; j < 10000; j++){
19.       for(int k = 0; k < 10000; k++){
20.         int a = j * k;
21.       }
22.     }
23.   }
24. }
26. int main()
27. {
28.   string thName1="Thread 1";
29.   string thName2="Thread 2";
30.   thread thWriteMsg1(&writeMsg, thName1);
31.   thread thWriteMsg2(&writeMsg, thName2);
33.   time_t clock;
35.   for (int i = 0; i < 100; i++){
36.     time(&clock);
37.     cout << "MAIN: " << ctime(&clock);
38.     for(int j = 0; j < 10000; j++){
39.       for(int k = 0; k < 10000; k++){
40.         int a = j * k;
41.       }
42.     }
43.   }
45.   thWriteMsg1.join();
46.   thWriteMsg2.join();
48.   return EXIT_SUCCESS;
49. }

testThread3.cppをダウンロード

実際の動きは「testThread2」と同じになる。今のところ、どちらの方法を使うかは好みかなと思っているが、複雑になってきたらboost::bindを使ってオブジェクトかしといた方が管理が楽になるのだろうかと思っている。