- ベストアンサー
pthreadの使い方
現在、pThreadを利用して、Windows とubuntu上で、テストしています。 そこで、質問なのですが、例えばCPU４つのコンピューターに１０個の重たい処理をする場合。 CPUをフルに使うために、まず４つのスレッドを作り、処理が早くおわったものから、次の処理をさせたいのですが、書き方がピンといまいちきません。教えていただけませんか？ むしろ最初から10個のスレッドを作成したほうがいいのでしょうか？
- みんなの回答 （1）
- 専門家の回答
質問者が選んだベストアンサー
関連するQ&A
- クラス内でのpthread_createに関して
Ｃ言語初心者です。 下記のようなソースにて、クラス内でのスレッドを行うことが目的です。 しかし、下記のpthread_createにてコンパイルエラーとなります。 キャストエラーのようなのですが、キャスト方法がわかりません。 初歩的な質問で、大変申し訳御座いませんが、ご教授頂けませんでしょうか？ ################################################################ #include <stdio.h> #include <pthread.h> // Testクラス class Test{ private: // スレッド処理 void testThread() { printf("### THREAD START ###\n"); return; } public: // スレッド開始 void threadStart() { // スレッド生成戻り値 int status; // スレッド pthread_t thread; // スレッド生成 status = pthread_create( &thread, NULL, (void*(*)(void*))testThread, NULL ); // スレッド生成結果 if ( status != 0 ) { printf("ERR!! pthread_create NG\n"); } return; } }; // メイン実行 int main(int argc, char *argv[]) { // Testクラスオブジェクト Test test; printf("### TEST START ###\n"); test.threadStart(); printf("### TEST E N D ###\n"); return 0; } ################################################################ 宜しくお願い致します。 以上です。
- 締切済み
- C・C++・C#
- pthread_mutex_lock の応答時間
HP-UX上でCを使ってpthreadプログラムを記述しています。 mutexを競合するスレッドが2つあり、 A) pthread_mutex_lock(&mutex) B) pthread_mutex_lock(&mutex) A) pthread_mutex_unlock(&mutex) の流れで処理が流れています。 この時、A)がlockを解放してからB)がlockを獲得できるまで(=pthread_mutex_lockの応答が返ってくるまで)に多少の時間がかかってしまうことはありうるのでしょうか。(現在発生している事象では、0.002秒程度) マシン性能にも拠ると思いますし、B)スレッドが再開するときのCPU割り当てに時間がかかった等も考えられるのかとは思いますが、スレッドライブラリとしての動きが知りたいです。
- ベストアンサー
- C・C++・C#
- pthread_cond_wait での mutex
以下の様なサンプルプログラム（一部省略）があります。 bossスレッドが1秒ごとにworkerスレッドを起こして、workerスレッドは処理後、再び眠ります。 worker () { while (...) { * pthread_mutex_lock(&g_lock); pthread_cond_wait(&g_signal, &g_lock); * pthread_mutex_unlock(&g_lock); : } } boss() { while (...) { wait( 1 ); * pthread_mutex_lock(&g_lock); pthread_cond_signal(&g_signal) * pthread_mutex_unlock(&g_lock); } } waitで待機し、signalで起こされるのはわかるのですが、 mutexでロックしている意味がわかりません。 mutexが不必要な処理の場合、*部分はいらないのでしょうか？
- ベストアンサー
- C・C++・C#
- pthread_attr_tへの値の代入について
スレッドを作成する際に、 属性としてPTHREAD_CREATE_DETACHEDを指定したいのですが、 その際pthread_attr_tをどのように設定したらよいかわかりません。 現在書いているコードは pthread pt; pthread_attr_t* attr; pthread_attr_init(attr); pthread_attr_setdetachstate(attr,PTHREAD_CREATE_DETACHED); if (pthread_create(&pt,attr,NULL,NULL) != 0){ perror("thread_create()"); exit(1); } 上記のようなものです。(スレッド作成部分のattr以外の 引数は適当です) これでコンパイルすると 警告: 変数 attr には値が代入されていません. と、警告が出てしまいます。 これを解消するにはどう修正したらよいのでしょうか？
- ベストアンサー
- C・C++・C#
- pthread_self APIの高速化
HP-UX上でCを使ってスレッドプログラムを書いています。 プログラム内部でスレッドIDを変数に保持して、その変数を元に、pthread_detachなどのAPIをコールするような作りになっているのですが、pthread_self APIで毎回、自スレッドIDを取得するようにすると、処理スピードは遅くなるのでしょうか。（どれくらい？気にするほど？） 感覚的には遅くなりそうな気がしてはいますが、プログラム変数の場合だと、予期しない変数の書き換えが発生した場合（これはこれでバグですので対応が必要になりますが・・・）などに余計な影響を受けることになり、どっちが得策なのか考えあぐんでいます。
- ベストアンサー
- C・C++・C#
- pthread_cond_waitとptherad_cond_signal
pthread_cond_waitで寝ているthreadに対して、ptherad_cond_signalにて起こして、そのthreadが再度寝るまでの間にpthread_cond_signalが複数回(2回として）Callされた場合、どのような挙動になるのでしょうか？ 最初のSignalをA、以下B,Cとすると A->cond_wait->B->cond_wait->C となるのでしょうか？ 宜しくお願い致します。
- ベストアンサー
- C・C++・C#
- pthread_cond_wait 取りこぼし？
はじめまして。 pthreadのお勉強がてら、パイプライン処理を実装してみようととりあえず実証コードを書いてみましたが、うまく意図した動きをしてくれません。 やりたいことは、処理ステージが２つあって、メインからステージ１をキックし、ステージ１は自分の処理が終わったらステージ２をキックするといった動作です。（メイン、ステージ１、ステージ２を並列に動作させたい） 取りあえず連鎖的に動作するか試したいだけなので、ステージ間のデータの受け渡しとかは、後で考えるとします。 それで、以下のような単純なコードを書きました。 期待する結果は、最後に表示される数値が 10000, 10000, 10000 になることですが、実際は、10000, 4401, 4401 のようにステージ１，２が少なくなります。 一応、それなりに調べて条件変数のセオリーに従い書いたつもりなのですが、どうしてこうなるか、ご教授ください。 test.c （空白を全角にしてあります） ------ #include <pthread.h> #include <stdio.h> #include <stdlib.h> #include <string.h> pthread_mutex_t mutex1, mutex2; pthread_cond_t cond1, cond2; int ready1, ready2; int end1, end2; int count1, count2; void * stage1( void *arg ) { pthread_mutex_lock( &mutex1 ); while( 1 ) { /* wait for my signal & job */ while ( ready1 == 0 ) { pthread_cond_wait( &cond1, &mutex1 ); } if ( end1 == 1 ){ /* is shutdown thread */ break; } /* my job. */ count1++; /* job clear */ ready1 = 0; /* forward next stage */ pthread_mutex_lock( &mutex2 ); ready2 = 1; pthread_cond_signal( &cond2 ); pthread_mutex_unlock( &mutex2 ); } pthread_mutex_unlock( &mutex1 ); return NULL; } void * stage2( void *arg ) { pthread_mutex_lock( &mutex2 ); while( 1 ) { while ( ready2 == 0 ) { pthread_cond_wait( &cond2, &mutex2 ); } if ( end2 == 1 ){ break; } count2++; ready2 = 0; } pthread_mutex_unlock( &mutex2 ); return NULL; } int main( ) { int i; pthread_t t1, t2; pthread_mutex_init( &mutex1, 0 ); pthread_cond_init ( &cond1, 0 ); ready1 = 0; end1 = 0; count1 = 0; pthread_create( &t1, 0, stage1, NULL ); pthread_mutex_init( &mutex2, 0 ); pthread_cond_init ( &cond2, 0 ); ready2 = 0; end2 = 0; count2 = 0; pthread_create( &t2, 0, stage2, NULL ); for ( i=0; i<10000; i++ ){ pthread_mutex_lock( &mutex1 ); ready1 = 1; pthread_cond_signal( &cond1 ); pthread_mutex_unlock( &mutex1 ); } pthread_mutex_lock( &mutex1 ); ready1 = 1; end1 = 1; pthread_cond_signal( &cond1 ); pthread_mutex_unlock( &mutex1 ); pthread_join(t1, 0 ); pthread_cond_destroy( &cond1 ); pthread_mutex_destroy( &mutex1 ); pthread_mutex_lock( &mutex2 ); ready2 = 1; end2 = 1; pthread_cond_signal( &cond2 ); pthread_mutex_unlock( &mutex2 ); pthread_join(t2, 0 ); pthread_cond_destroy( &cond2 ); pthread_mutex_destroy( &mutex2 ); printf("%d, %d, %d\n", i, count1, count2); return 0; } ------ gcc -o test -lpthread test.c 以上
- ベストアンサー
- C・C++・C#
- pThreadのメインでなぜsleep?
Windowsとlinux環境で、pthreadをもちいて、動作確認などをしています。 こちらのサンプルを下に、じっけんしていたのですが。 http://www.ibm.com/developerworks/jp/linux/library/l-posix3/ ここのメインのコードに, sleep(2) という表記があります。 なぜここでsleepをしなければいけないんでしょうか？ 実際に、削除してみると、スレッドの作業が途中で終了してしまいました。 このやり方だと、作業時間がわかっている場合は、いいのですが、 もしどれぐらい処理にかかるかわからない場合、困ると思います。 どのようにすれば、sleepを使わずに作業が終わるのをまつことができるでしょうか？ int main(void) { int x; wnode *mywork; initialize_structs(); /* CREATION */ if (create_threads()) { printf("Error starting threads... cleaning up.\n"); join_threads(); dabort(); } pthread_mutex_lock(&wq.control.mutex); for (x=0; x<16000; x++) { mywork=malloc(sizeof(wnode)); if (!mywork) { printf("ouch! can't malloc!\n"); break; } mywork->jobnum=x; queue_put(&wq.work,(node *) mywork); } pthread_mutex_unlock(&wq.control.mutex); pthread_cond_broadcast(&wq.control.cond); printf("sleeping...\n"); sleep(2); printf("deactivating work queue...\n"); control_deactivate(&wq.control); /* CLEANUP */ join_threads(); cleanup_structs(); }
- ベストアンサー
- C・C++・C#
- pthread_createでタスクの構造体にて
pthread_createという関数でeventというスレッドタスクを作成したく、次のように宣言しました。 if(pthread_create(&thread03 , NULL , thread_func03 ,(void*)&pth) !=0) perror("pthread_create()"); ちなみに、pth_argは次のような構造です。 typedef struct{ char *c; int i; long l; }pth_arg; /* thread_func関数に値を渡すときの構造体 */ 実際のタスク void *event(void *param) { pth_arg *this_arg; this_arg = param; -----(中略)------------------------- } このような形ビルドも正常に完了し、this_argの構造をそのままこのタスク内で使用することも可能なのですが、その後に typedef struct{ char *c; int i; long l; }env_t; /* 次のような構造体もこのタスク内に追加したくなり、 実際のタスク env_t * pEnv; //グローバル宣言 void *event(void *param) { pth_arg *this_arg; this_arg = param; pEnv->i = 0x01; -----(中略)------------------------- } このように、env_t * pEnv;でグローバル宣言で宣言して 値を代入するようなコードを書くと、ビルドはOKなのですが、実行すると Segmentation fault (core dumped) このエラーが出てきて動作が停止してしまいます。 これを解決方法などありませんでしょうか? どうぞ、ご教示頂きますようお願い致します。
- ベストアンサー
- C・C++・C#
- スレッドを効率的に使うとは？
C言語＆C++で、pthreadを利用して、ファイルのコンバートをいかに早くできるかに挑戦します。 たとえば、CPUが２つある場合。 スレッドが１つだと、CPUの５０％の性能しか出ない。だから、二つ目のスレッドを使うという風に理解しています。スレッドを二つ使うことで、１００％CPUの力を引き出せる。 しかし、スレッドはCPUの数以上に、生成できるという風にも理解しています。もちろん上限はある。 ただし、その場合は２つのCPUをある時間単位でくぎって、スレッドにふりわけて使い回しをする。 ということは、フルにCPUを最速で使いたい場合は、CPUの数だけスレッドを生成して利用するという理解でいいでしょうか？ また、大きなファイルの場合、ファイルにメモリに読み込んで二つにわけて、２つのスレッドを同時に走らせてはやく終わらせるということも可能なのでしょうか？おそらく、RAWのデータならできるけど、何かフォーマットがあるものは難しそうですね。
- ベストアンサー
- C・C++・C#
補足
ご回答ありがとうございます。 もし参考になるサンプルのリンク等あったらおしえていただけませんか？ 恥ずかしながら、セマフォと、ミューテックスについて少しは調べたものの、排他処理をする ということぐらいしか知っていませんでした。