我正在编写一个创建两个线程的程序。 每个线程负责读取一个文本文件,每行有一个字符。
第一种格式如下:
h 0 h 0 ...
第二个格式如下:
0 i 0 i 0 i
有时可能会有多个字母在彼此之后,或者在彼此之后有多个零。 但是,可以肯定的是,如果一个文件的一行上有一个字母,则第二个文件的相应行将为0,反之亦然。
线程应该继续将文件输入读入全局char数组,直到它们达到零。 此时,他们允许其他线程接管。 他们一直来回走,直到两个文件完全被读取。
在这一点上,当我跑步的时候,我得到的变化是:(1)很多h后跟很多我或(2)( 正确答案 )连续的hihihi流,或者(3)有时很多我跟着很多h。 所以,我知道我的同步方法已关闭。
这是我的一个线程的示例:(注意两个线程完全相同,除了正在打开的文件。)
void *getMessage1() { FILE *studentOne = fopen("Student1", "r"); size_t howManyChars; char *placeHolderChars; int count = 1; while (count 0) { placeHolderChars[1] = ' '; } 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; }
我将非常感谢有关如何更好地使用锁定,解锁,等待和/或信号来创建具有一致结果的工作同步技术的任何指导。
这是一个尝试做一个你想要的程序。 但是测试不充分;)
#include #include #include #include #include using std::cout; using std::ifstream; using std::string; const string FILE1("file1.txt"); const string FILE2("file2.txt"); enum State { UNINITIALIZED, THREAD_ONE_READS, THREAD_TWO_READS }; struct ThreadInfo { State state; string filename; }; State state = UNINITIALIZED; pthread_mutex_t mut = PTHREAD_MUTEX_INITIALIZER; pthread_cond_t cond = PTHREAD_COND_INITIALIZER; void* thread_func(void* arg) { // Open file 'h'. ThreadInfo ti = *reinterpret_cast(arg); ifstream infile; infile.open (ti.filename.c_str(), std::ifstream::in); // while (not EOF) // Read 'h' or 'i': until 0 reached. Wake up other thread. string line; getline(infile, line); while (infile.good()) { cout << "Thread " << pthread_self() << " read " << line << 'n'; pthread_mutex_lock(&mut); while (state == ti.state) { pthread_cond_wait(&cond, &mut); } pthread_mutex_unlock(&mut); assert(line.length() == 1); if (line[0] == '0') { pthread_mutex_lock(&mut); state = ti.state; cout << "Got 0, transferring, setting state to " << state << 'n'; pthread_cond_signal(&cond); pthread_mutex_unlock(&mut); } else { cout << "Read char: " << line << 'n'; } getline(infile, line); } pthread_mutex_lock(&mut); state = ti.state; cout << "Finishing thread, transferring, setting state to " << state << 'n'; pthread_cond_signal(&cond); pthread_mutex_unlock(&mut); } int main() { // Create thread 1 // Create thread 2 pthread_t thread_one_handle; pthread_t thread_two_handle; state = THREAD_ONE_READS; int result; ThreadInfo info1 = { THREAD_TWO_READS, FILE1 }; result = pthread_create(&thread_one_handle, NULL, thread_func, &info1); assert(result == 0); ThreadInfo info2 = { THREAD_ONE_READS, FILE2 }; result = pthread_create(&thread_two_handle, NULL, thread_func, &info2); assert(result == 0); result = pthread_join(thread_one_handle, NULL); assert(result == 0); result = pthread_join(thread_two_handle, NULL); assert(result == 0); cout << "main(): joined both worker threads, ending program.n"; return 0; }
以上就是c/c++开发分享Pthread同步:两个文本文件的返回和读取相关内容,想了解更多C/C++开发(异常处理)及C/C++游戏开发关注计算机技术网(www.ctvol.com)!)。
本文来自网络收集,不代表计算机技术网立场,如涉及侵权请联系管理员删除。
ctvol管理联系方式QQ:251552304
本文章地址:https://www.ctvol.com/c-cdevelopment/522254.html