1

私は自分の pthreads プログラムをある程度動作させることができました。基本的に、スレッド 1 が CPU 1 で実行され、スレッド 2 が CPU 2 で実行され、スレッド 3 が CPU 3 で実行され、スレッド 4 が CPU 4 で実行されるように、4 つのスレッドのアフィニティを手動で設定しようとしています。

コンパイル後、コードはいくつかのスレッドで機能しますが、他のスレッドでは機能しません (スレッド 1 は機能しないようです) が、同じコンパイル済みプログラムを数回実行すると、異なる結果が得られます。

例:
hao@Gorax:~/Desktop$ ./a.out
スレッド 3 は CPU 3 で実行されています
pthread_setaffinity_np: 無効な引数
スレッド スレッド 2 は CPU 2 で実行されています
hao@Gorax:~/Desktop$ ./a.out
スレッド 2は CPU 2 で実行されています
pthread_setaffinity_np: 無効な引数
pthread_setaffinity_np: 無効な引数
スレッド 3 は CPU 3 で実行されています
スレッド 3 は CPU 3 で実行されています
hao@Gorax:~/Desktop$ ./a.out
スレッド 2 は CPU 2 で実行されています
pthread_setaffinity_np: 無効です引数
スレッド 4 は CPU 4 で実行されています スレッド 4 は CPU
4 で実行されています
hao@Gorax:~/Desktop$ ./a.out
pthread_setaffinity_np: 無効な引数

私の質問は、「なぜこれが起こるのですか? また、メッセージが 2 回出力されることがあるのはなぜですか?」

コードは次のとおりです。

#define _GNU_SOURCE
#include <stdio.h>
#include <pthread.h>
#include <stdlib.h>
#include <sched.h>
#include <errno.h>

#define handle_error_en(en, msg) \
               do { errno = en; perror(msg); exit(EXIT_FAILURE); } while (0)

void *thread_function(char *message)
{
    int s, j, number;
    pthread_t thread;
    cpu_set_t cpuset;

    number = (int)message;
    thread = pthread_self();    
    CPU_SET(number, &cpuset);

    s = pthread_setaffinity_np(thread, sizeof(cpu_set_t), &cpuset);
    if (s != 0)
    {
        handle_error_en(s, "pthread_setaffinity_np");
    }

    printf("Thread %d is running on CPU %d\n", number, sched_getcpu());

    exit(EXIT_SUCCESS);
}

int main()
{
    pthread_t thread1, thread2, thread3, thread4;
    int thread1Num = 1;
    int thread2Num = 2;
    int thread3Num = 3;
    int thread4Num = 4;
    int thread1Create, thread2Create, thread3Create, thread4Create, i, temp;

    thread1Create = pthread_create(&thread1, NULL, (void *)thread_function, (char *)thread1Num);
    thread2Create = pthread_create(&thread2, NULL, (void *)thread_function, (char *)thread2Num);
    thread3Create = pthread_create(&thread3, NULL, (void *)thread_function, (char *)thread3Num);
    thread4Create = pthread_create(&thread4, NULL, (void *)thread_function, (char *)thread4Num);

    pthread_join(thread1, NULL);
    pthread_join(thread2, NULL);
    pthread_join(thread3, NULL);
    pthread_join(thread4, NULL);

    return 0;
}
4

1 に答える 1

2

最初の CPU は、CPU 1ではなくCPU 0です。したがって、threadNums を変更する必要があります。

int thread1Num = 0;
int thread2Num = 1;
int thread3Num = 2;
int thread4Num = 3;

cpuset次のように CPU_ZERO() マクロで初期化する必要があります。

CPU_ZERO(&cpuset);
CPU_SET(number, &cpuset);

また、すべてのスレッドでプロセス全体が停止するため、スレッドから exit() を呼び出さないでください。

終了 (EXIT_SUCCESS);  
0 を返します。// 代わりにこれを使用するか、pthread_exit() を呼び出します
于 2010-04-02T04:49:20.543 に答える