1

別の pthread から pthread をウェイクアップしたいのですが、しばらくしてからです。pthread_cond_wait を使用したシグナルまたは pthread_signal を使用して別のスレッドを起動できることは知っていますが、これをスケジュールする方法がわかりません。状況は次のようになります。

THREAD 1:
========
while(1)
    recv(low priority msg); 
    dump msg to buffer 


THREAD 2:
========
while(1)
    recv(high priority msg); 
    ..do a little bit of processing with msg .. 
    dump msg to buffer 

    wake(THREAD3, 5-seconds-later);  <-- **HOW TO DO THIS? ** 
    //let some msgs collect for at least a 5 sec window. 
    //i.e.,Don't wake thread3 immediately for every msg rcvd. 


THREAD 3: 
=========
while(1)
    do some stuff .. 
    Process all msgs in buffer 
    sleep(60 seconds).

ウェイクアップをスケジュールする簡単な方法 (毎秒ウェイクアップし、スレッド 3 がウェイクアップする予定のエントリがあるかどうかを決定する 4 番目のスレッドを作成する以外)。キューに優先度の低いメッセージしかない場合、スレッド 3 を頻繁にウェイクアップしたくありません。また、メッセージはバースト (単一のバーストで 1000 の優先度の高いメッセージなど) で送信されるため、メッセージごとにスレッド 3 をウェイクアップしたくありません。それは本当に物事を遅くします（ウェイクアップするたびに行う他の処理がたくさんあるため）.

ubuntu PCを使用しています。

4

3 に答える 3

2

pthread_cond_tpthread API を介して利用可能なオブジェクトの使用はどうですか? そのようなオブジェクトをスレッド内で共有し、それらに適切に作用させることができます。
結果のコードは次のようになります。

/*
 * I lazily chose to make it global.
 * You could dynamically allocate the memory for it
 * And share the pointer between your threads in
 * A data structure through the argument pointer
 */
pthread_cond_t cond_var;
pthread_mutex_t cond_mutex;
int wake_up = 0;

/* To call before creating your threads: */
int err;
if (0 != (err = pthread_cond_init(&cond_var, NULL))) {
    /* An error occurred, handle it nicely */
}
if (0 != (err = pthread_mutex_init(&cond_mutex, NULL))) {
    /* Error ! */
}
/*****************************************/

/* Within your threads */
void *thread_one(void *arg)
{
    int err = 0;
    /* Remember you can embed the cond_var
     * and the cond_mutex in
     * Whatever you get from arg pointer */

    /* Some work */
    /* Argh ! I want to wake up thread 3 */
    pthread_mutex_lock(&cond_mutex);
    wake_up = 1; // Tell thread 3 a wake_up rq has been done
    pthread_mutex_unlock(&cond_mutex);
    if (0 != (err = pthread_cond_broadcast(&cond_var))) {
        /* Oops ... Error :S */
    } else {
        /* Thread 3 should be alright now ! */
    }
    /* Some work */
    pthread_exit(NULL);
    return NULL;
}

void *thread_three(void *arg)
{
    int err;
    /* Some work */
    /* Oh, I need to sleep for a while ...
     * I'll wait for thread_one to wake me up. */
    pthread_mutex_lock(&cond_mutex);
    while (!wake_up) {
        err = pthread_cond_wait(&cond_var, &cond_mutex);
        pthread_mutex_unlock(&cond_mutex);
        if (!err || ETIMEDOUT == err) {
            /* Woken up or time out */        
        } else {
            /* Oops : error */
            /* We might have to break the loop */
        }
        /* We lock the mutex again before the test */
        pthread_mutex_lock(&cond_mutex);
    }
    /* Since we have acknowledged the wake_up rq
     * We set "wake_up" to 0. */
    wake_up = 0;
    pthread_mutex_unlock(&cond_mutex);
    /* Some work */
    pthread_exit(NULL);
    return NULL;
}

タイムアウト後にスレッド 3 にブロッキング呼び出しを終了させたい場合は、代わりにpthread_cond_wait()使用することを検討してpthread_cond_timedwait()ください (注意深く読んでください。指定するタイムアウト値は絶対時間であり、超えたくない時間ではありません)。
タイムアウトにpthread_cond_timedwait()なると、エラーが返されETIMEDOUTます。

編集: ロック/ロック解除呼び出しでエラーチェックをスキップしました。この潜在的な問題を処理することを忘れないでください!

EDIT²：コードを少し見直しました

于 2013-01-30T13:01:18.133 に答える
0

目覚めたスレッドにそれ自体を待機させることができます。目覚めているスレッドで：

pthread_mutex_lock(&lock);
if (!wakeup_scheduled) {
    wakeup_scheduled = 1;
    wakeup_time = time() + 5;
    pthread_cond_signal(&cond);
}
pthread_mutex_unlock(&lock);

待機中のスレッド：

pthread_mutex_lock(&lock);
while (!wakeup_scheduled)
    pthread_cond_wait(&cond, &lock);
pthread_mutex_unlock(&lock);

sleep_until(wakeup_time);

pthread_mutex_lock(&lock);
wakeup_scheduled = 0;
pthread_mutex_unlock(&lock);
于 2013-01-30T12:44:01.957 に答える
0

現在の時間を 1 つ前のセーブと比較してみませんか?

time_t last_uncond_wakeup = time(NULL);
time_t last_recv = 0;

while (1)
{
    if (recv())
    {
        // Do things
        last_recv = time(NULL);
    }

    // Possible other things

    time_t now = time(NULL);
    if ((last_recv != 0 && now - last_recv > 5) ||
        (now - last_uncond_wakeup > 60))
    {
        wake(thread3);
        last_uncond_wakeup = now;
        last_recv = 0;
    }
}
于 2013-01-30T12:36:20.610 に答える