0

我有两个类评估线程，但我无法将信号从一个发送到另一个，一些想法为什么它不起作用：

第一类：

#include "timer.h"
#include <ncurses.h>
#include <stdlib.h>
#include <time.h>
#include <unistd.h>
#include "mutexy.h"

Timer::Timer() {
}

Timer::~Timer() {
}

void Timer::startThread() {
    pthread_create(&thread, NULL, runInstance, reinterpret_cast<void *>(this));
}

void Timer::joinThread() {
    pthread_join(thread, NULL);
}

void Timer::init() {
    this->hh = 0;
    this->day = 1;
    this->month = 1;
    this->year = 2011;
}

void Timer::run() {
    while(true) 
    {
        if(hh==24) {
            hh = 0;
            day++;
            if(day==31) {
                day=1;
                month++;
                if(month==13) {
                    year++;
                    month==1;
                }
            }
        }
        for (int i=0; i<10; i++) {
            if(hh==7) {
                hh=20;
                pthread_cond_signal(&brak_biletow_treshold);
            }
        }

        sleep(1);
        hh++;
        pthread_yield();
    }
}

void* Timer::runInstance(void *instance) {
    Timer *d = reinterpret_cast<Timer *>(instance);

    d->run();

    return NULL;
}

类2：

#include "flight_list.h"
#include <ncurses.h>
#include <stdlib.h>
#include <time.h>
#include <unistd.h>
#include "mutexy.h"

string cities[8] = {"Warszawa","Berlin","Paryz","Londyn","Dublin","Madryt","Wieden","Moskwa"};


FlightList::FlightList() {
    srand(time(NULL));
}

FlightList::~FlightList() {
}

void FlightList::startThread() {
    pthread_create(&thread, NULL, runInstance, reinterpret_cast<void *>(this));
}

void FlightList::joinThread() {
    pthread_join(thread, NULL);
}

void FlightList::init() {
    flightTab = new Flight *[10];
    for (int i=0; i<10; i++) {
        int city = rand()%7+1;
        flightTab[i] = new Flight(i*2+2,i+2,1,2011,60,cities[0],cities[city]); 
    }
}

void FlightList::run() {
    while(true) 
    {
        pthread_mutex_lock(&bilety_mutex);
        pthread_cond_wait(&brak_biletow_treshold, &bilety_mutex);
        for (int i=0; i<10; i++) {
                for(int i=0; i<9; i++)
                    flightTab[i] = flightTab[i+1];
                int city = rand()%7+1;
                flightTab[9] = new Flight(4,10,2,2011,60,cities[0],cities[city]); 

        }
        pthread_mutex_unlock(&bilety_mutex);
        pthread_yield();
    }
}

void* FlightList::runInstance(void *instance) {
    FlightList *d = reinterpret_cast<FlightList *>(instance);

    d->run();

    return NULL;
}

以及带有互斥锁和 cond_t 的头文件：

#include <pthread.h>

static pthread_mutex_t bilety_mutex;
static pthread_mutex_t loty_mutex;
static pthread_cond_t brak_biletow_treshold = PTHREAD_COND_INITIALIZER

;

互斥锁正在工作，但线程没有接收到信号：S

4

2 回答 2

2

每个翻译单元都有自己的brak_biletow_treshold实例，因为您已经声明了它们static（这实际上将范围限制为当前翻译单元）。

您需要更改声明和访问“全局变量”的方式。我建议您将条件传递给两个类的构造函数。

于 2012-05-21T11:37:28.053 回答
1

这是因为每个包含头文件的 C 源文件都有自己的静态变量副本。它们不在翻译单元之间共享。

互斥锁似乎只起作用，因为它们在这种情况下的作用是不相互影响。对于互斥体，它看起来一直工作到您的数据被破坏的地步。

对于条件变量，分离意味着它看起来不像在工作，实际上它不是。

extern一种解决方案是在头文件声明中标记它们并在某个 C 文件中定义它们，例如：

my_thread_stuff.h:
    extern pthread_mutex_t bilety_mutex;
    extern pthread_mutex_t loty_mutex;
    extern pthread_cond_t brak_biletow_treshold;

global_thread_stuff.c:
    #include "my_thread_stuff.h"
    pthread_mutex_t bilety_mutex;
    pthread_mutex_t loty_mutex;
    pthread_cond_t brak_biletow_treshold = PTHREAD_COND_INITIALIZER;
于 2012-05-21T11:37:50.700 回答