pthreads_setaffinity_np: неверный аргумент? - PullRequest
Новая
       18

pthreads_setaffinity_np: неверный аргумент?

1 голос
/ 02 апреля 2010

Мне удалось заставить мою программу pthreads работать.По сути, я пытаюсь вручную установить сходство 4 потоков, чтобы поток 1 работал на ЦП 1, поток 2 работал на ЦП 2, поток 3 работал на ЦП 3, а поток 4 работал на ЦП 4.

Послекомпилируя, мой код работает для нескольких потоков, но не для других (кажется, что поток 1 никогда не работает), но запуск одной и той же скомпилированной программы несколько раз дает мне разные результаты.

Например:
hao @Gorax: ~ / Desktop $ ./a.out
Поток 3 работает на ЦП 3
pthread_setaffinity_np: Неверный аргумент
Поток 2 потока работает на ЦП 2
hao @ Gorax: ~ / Desktop $./a.out
Поток 2 работает на ЦП 2
pthread_setaffinity_np: неверный аргумент
pthread_setaffinity_np: неверный аргумент
Поток 3 работает на ЦП 3
Поток 3 выполняется на ЦП 3
hao @ Gorax: ~ / Desktop $ ./a.out
Поток 2 работает на ЦП 2
pthread_setaffinity_np: Неверный аргумент
Поток 4 работает на ЦП 4
Поток 4 работает наЦП 4
Хао @ Горакс: ~/ Desktop $ ./a.out
pthread_setaffinity_np: Неверный аргумент

Мой вопрос: «Почему это происходит?Кроме того, почему сообщение иногда печатается дважды? "

Вот код: 

#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;
}

1 Ответ

2 голосов
/ 02 апреля 2010

Первый ЦП - ЦП 0 , а не ЦП 1 . Таким образом, вы захотите изменить свои номера нитей: 

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

Вы должны инициализировать cpuset с помощью макроса CPU_ZERO () следующим образом: 

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

Также не вызывайте exit () из потока, поскольку он остановит весь процесс со всеми его потоками: 

<strike>exit(EXIT_SUCCESS);</strike>  
return 0; // Use this instead or call pthread_exit()
...