Однопроцессная программа содержит 6 потоков. Каждый поток выполняет свою поточную функцию в бесконечном цикле. В поточной функции выводится идентификатор потока tid, далее поток засыпает на 1 секунду, и, проснувшись, передаёт управление следующему потоку (1, 2, .., 6, 1...). Программа должна воспроизвести несколько циклов заданного чередования потоков, после чего принудительно завершается.
Вот мой код.
#include <stdio.h>
#include <pthread.h>
typedef struct {
int id;
} param;
static int current = 0;
pthread_mutex_t mutex = PTHREAD_MUTEX_INITIALIZER;
pthread_cond_t condvar = PTHREAD_COND_INITIALIZER;
void *function(void *arg)
{
param * thread_number = (param*)arg;
while(1)
{
pthread_mutex_lock(&mutex);
while (thread_number->id != current) pthread_cond_wait(&condvar,&mutex);
if (thread_number->id == current)
{
printf("THIS IS THREAD #%d OF PROCESS #%d\n", pthread_self(), getpid());
current = (current + 1) % 6
//sleep(1);
}
}
pthread_cond_signal(&condvar);
pthread_mutex_unlock(&mutex);
}
int main()
{
int i;
param p;
pthread_t threads[6];
for (i = 0; i < 6; i++)
{
p.id = i;
pthread_create(&threads[i], NULL, function, (void*)&p);
sleep(1);
}
for (i = 0; i < 6; i++)
pthread_join(threads[i], NULL);
}
В main'е я в цикле создаю 6 потоков с помощью pthread_create, передаю им счётчик цикла и потом использую его в качестве номера процесса. Потом жду их завершения с помощью pthread_join.
В первый раз всё хорошо, все 6 потоков отрабатывают, но потом они зависают и не работают. Посмотрел в pidin (запускаю в qnx v6.3.2, после 1 прогонки все потоки находятся в состоянии condvar (см. вложения). Помогите исправить =(
while (thread_number->id != current) pthread_cond_wait(&condvar,&mutex);
- наппример, приcurrent
равному такому числу, которого нет в потоках, типа 0 или 8 ?pthread_cond_signal()
должен быть внутри цикла — иначе другие процессы не узнают, что условие изменилось... ЗЫ: и в вопросе что-то не так с фигурными скобками...pthread_cond_signal()
в цикл if, но проблема не решилась, более того, потоки начали работать вразнобойcurrent
на 6, то есть её значение будет в интервале [0,5], которые я и использую для потоков