我在写一个创建两个线程的程序。每个线程负责读取一个文本文件,每行一个字符。Pthread同步:两个文本文件的前后读取
h
0
h
0
...
第二的格式如下::
第一像被格式化
0
i
0
i
0
i
有时可以有后彼此多个字母,或彼此先后多个零。但是,一个确定的是,如果一个文件的一行上有一个字母,第二个文件的相应行将有一个0,反之亦然。
线程应该保持读取文件输入到全局字符数组中,直到它们达到零。此时,他们允许另一个线程接管。他们会一直往前走,直到两个文件都被完全读取。 (1)很多h的变化,其次是许多i或(2)(正确答案)hihihi的连续流,或(3)有时很多我的其次是许多h。所以,我知道我的同步方法已关闭。
这是我的线程中的一个的示例: (注意两个线程是完全一样的,除了被打开的文件。)
void *getMessage1()
{
FILE *studentOne = fopen("Student1", "r");
size_t howManyChars;
char *placeHolderChars;
int count = 1;
while (count < 501)
{
placeHolderChars = NULL;
getline(&placeHolderChars, &howManyChars, studentOne);
if(strcmp(placeHolderChars, "0\n") == 0) //if we've reached a zero
{
pthread_mutex_unlock(&lock);
}
else
{ while(1)
{
if(pthread_mutex_trylock(&lock) == 0)
{
break;
}
}
if(strlen(placeHolderChars)>0)
{
placeHolderChars[1] = '\0';
}
strcat(message,placeHolderChars);
}
free(placeHolderChars);
if(feof(studentOne))
{
pthread_mutex_unlock(&lock); //unlock
fclose(studentOne);
break;
}
count++;
}
return 0;
}
这是我的主要方法:
int main(void)
{
pthread_t id1;
pthread_t id2;
pthread_create((&id1), NULL, getMessage1, NULL);
pthread_create((&id2), NULL, getMessage2, NULL);
pthread_join(id1, NULL);
pthread_join(id2, NULL);
int j;
for (j = 0; j < 1001; j++)
{
printf ("%c ",message[j]);
}
return 0;
}
如果我能更好地使用锁定,解锁,等待和/或信号创建具有一致结果的工作同步技术,我将不胜感激。
信号量。你不能用互斥锁来做到这一点。多重复数据删除。 –
我的教授实际上建议我们使用互斥体,因为他声称它会使它容易得多。所以,我应该废除互斥体并使用二进制信号量或什么? – Selena
此外,我应该考虑只有一个函数,这两个线程使用? (然后他们通过文件作为参数?)会有什么区别? – Selena