0

我正在使用 pthreads 和互斥进行分配。我必须创建 n 个打印服务器和 m 个打印客户端，它们每个都有 5 个打印作业。我们将创建线程，将作业通过大小为 4 的队列传递到打印服务器，然后打印该作业（即本例中的忙碌工作）。这是传递作业和服务作业的代码。

这些是客户端和服务器线程

void *PrintClient(void *arg){
int i;
char str[NUMJOBSPERCLIENT][100];

for(i=1;i<NUMJOBSPERCLIENT;i++){
    pthread_mutex_lock(&mutex);
    req.clientID = pthread_self();
    req.fileSize = rand_int(FILEMIN,FILEMAX);
    sprintf(str[i], "File_%d_%d",pthread_self(),i);
    req.fileName = str[i];
    append(req);
    pthread_mutex_unlock(&mutex);
    sleep(rand_int(1,3));
}//for
pthread_exit(NULL);
} // end PrintClient

void *PrintServer(void *arg){

pthread_mutex_lock(&mutex);
pthread_cond_wait(&cond,&mutex);
while(count > 0){
    take();
    count = count -1;
}
pthread_mutex_unlock(&mutex);
pthread_exit(NULL);
} // end PrintServer

这是从队列中添加或删除作业的代码。我知道错误就在这里，它与线程本身有关，但我一生都找不到它。到目前为止，调试器几乎没有任何帮助（我在大学 linux 服务器上运行，没有显示编译错误）。

void append(PrintRequest item){
BoundBuffer[count] = req;
printf("I am client %s\n",req.fileName);
count++;
if(count == BUFSIZE){
    printf("Buffer Size Reached\n");
    pthread_cond_signal(&cond);
}
} // end append

PrintRequest take(){
printf("Printing %s\n", BoundBuffer[count].fileName);
usleep(BoundBuffer[count].fileSize/PRINTSPEED);
printf("Finished Printing %s\n", BoundBuffer[count].fileName);
} // end take
4

1 回答 1

1

我猜分段错误是有信号的printf("Printing %s\n", BoundBuffer[count].fileName);，对吧？

在您的PrintClient文件中，您将文件名存储到局部变量str[][]中，并将指向该局部变量的指针复制为请求的一个参数req.fileName = str[i];。因此，指向的地址req.fileName被分配在客户端线程的堆栈上。

在服务器线程中处理请求时PrintServer，生成请求的客户端线程可能不再存在。结果是req.fileName指向一个不存在的地址（堆栈内存已经随着客户端线程的退出而被取消分配），然后当您在中取消引用此类地址时printf("Printing %s\n", BoundBuffer[count].fileName);，会发出分段错误信号。

于 2013-06-18T06:26:49.190 回答