- android - 多次调用 OnPrimaryClipChangedListener
- android - 无法更新 RecyclerView 中的 TextView 字段
- android.database.CursorIndexOutOfBoundsException : Index 0 requested, 光标大小为 0
- android - 使用 AppCompat 时,我们是否需要明确指定其 UI 组件(Spinner、EditText)颜色
我有以下代码:
/*//not important
FILE * INFILE;
list_file = optarg;
if( ( INFILE = fopen( list_file, "a+" ) ) == NULL ) {
fprintf( stderr, "Can't open input file\n");
exit(0);
}
*/
pthread_mutex_t input_queue;
pthread_mutex_init(&input_queue, NULL);
for( i = 0 ; i < number_thread; i++)
{
if( pthread_create( &thread_id[i], NULL, &work, NULL) != 0 )
{
i--;
fprintf(stderr, RED "\nError in creating thread\n" NONE);
}
}
for( i = 0 ; i < number_thread; i++)
if( pthread_join( thread_id[i], NULL) != 0 )
{
fprintf(stderr, RED "\nError in joining thread\n" NONE);
}
void * work(void * data)
{
unsigned long line;
char buf[512];
while ( !feof(INFILE) )
{
pthread_mutex_lock(&input_queue);
fgets((char *)&buf, sizeof(buf), INFILE);
if (buf[strlen (buf) - 1] == '\n')
buf[strlen (buf) - 1] = '\0';
line = (unsigned long)buf;
pthread_mutex_unlock(&input_queue);
do_work( line );
}
fclose(INFILE);
return NULL;
}
它从文件中读取行,但过了一会儿它意外退出,没有错误消息。我想我搞砸了什么。
我如何使用 pthreads 逐行读取文件,但尽可能保持代码不变(我的意思是不要弄乱整个程序)?
最佳答案
您正在关闭遇到 EOF 的第一个线程中的 INFILE
。之后其他线程将在关闭的文件上调用 feof()
— 并且可能调用 fclose()
— 这将破坏堆并且几乎肯定会导致崩溃。此外,您的换行代码可能会在 EOF 处运行缓冲区不足,请参阅下面的备注。
要解决此问题,请使用相同的互斥锁保护 feof()
和 fclose()
,并将 INFILE 设置为 NULL。获取互斥量时,检查 INFILE 是否为 NULL,如果是则立即返回:
for (;;) {
pthread_mutex_lock(&input_queue);
if (!INFILE) {
pthread_mutex_unlock(&input_queue);
break;
}
if (feof(INFILE)) {
INFILE = NULL;
pthread_mutex_unlock(&input_queue);
break;
}
fgets(buf, sizeof(buf), INFILE);
pthread_mutex_unlock(&input_queue);
// ...strip newline, do_work...
}
几点说明:
您的代码写入 buf[strlen(buf) - 1]
而不检查 strlen(buf)
是否为零。 buf
将在 EOF 处为空,因此这不是理论上的问题,它会在每次执行时恰好发生一次。
line
是 unsigned long
类型,但您正在为其分配一个指针值。这将在 long
不包含指针的平台上失败,例如 Win64。将 line
和 do_work
的参数声明为 char *
(或者 void *
如果它必须接受其他指针类型)相反。
避免将互斥体称为“队列”;在多线程编程队列中指的是producer-consumer aware FIFO .
您不需要使用互斥锁保护单个 stdio 函数,例如 fgets
。根据 POSIX 的规定,它们是 MT 安全的。 (但是,在我修改后的代码中,fgets()
确实需要受互斥锁保护,因为 INFILE
可能会在互斥锁未被持有时失效。)
(char *) &buf
没有意义。由于 buf
是一个 char
数组,它已经衰减为指向其第一个成员的指针,因此您只需将 buf
发送到 fgets
。如果您坚持使用地址运算符,正确的表达式是&buf[0]
。
正如 Carl Norum 所暗示的,feof()
可能不是您想要的,因为它只检测 fgets()
已经遇到的 EOF 条件。检查 EOF 的正确方法是测试 fgets()
是否返回空字符串 — 在去除换行符之前。
关于c - 使用 pthreads 逐行读取文件...意外退出,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/15042527/
关闭。这个问题不符合Stack Overflow guidelines .它目前不接受答案。 我们不允许在 Stack Overflow 上提出有关通用计算硬件和软件的问题。您可以编辑问题,使其成为
当我尝试在 db2 中创建表时,它抛出以下错误 $ db2 CREATE TABLE employee(emp_id INT NOT NULL, emp_name VARCHAR(100)) sh:
我有: while (i < l) { if (one === two) { continue; } i++; } 但是 JSLint 说: Problem at line 1 chara
所以我有这个代码: char inputs[10] = ""; int numInputs = 0; while (numInputs < 10){ char c; printf("E
var ninja = { name: 'Ninja', say: function () { return 'I am a ' + this.name; }
我收到一个我不明白的错误,请注意,我是编码新手,所以这可能是一个简单的错误。 #include using namespace std; int main() { //Initialise Fahr
我正在使用 javascript 和 react,由于某种原因,我收到了一个奇怪的 token 错误。 这是发生错误的代码: renderNavBar() { if (!this.us
Closed. This question is off-topic。它当前不接受答案。
由于某种我无法解释的原因,编译器正在输出一个错误,指出它发现了一个意外的#else 标记。 这发生在文件的开头: #if defined( _USING_MFC ) #include "stda
这个问题不太可能帮助任何 future 的访问者;它只与一个小的地理区域、一个特定的时间点或一个非常狭窄的情况有关,这些情况并不普遍适用于互联网的全局受众。为了帮助使这个问题更广泛地适用,visit
这个问题在这里已经有了答案: Difference between sh and Bash (11 个答案) 关闭 2 年前。 我正在编写一个简单的 bash 脚本,我在 XX `(' unexpe
关闭。这个问题是not reproducible or was caused by typos .它目前不接受答案。 此问题是由拼写错误或无法再重现的问题引起的。虽然类似的问题可能是 on-topic
我在 Windows 7 上编写了一个脚本,它不断给我一个错误“(此时出乎意料。”对于以下代码 if %vardns%=="NODNS" ( netsh interface ipv4 set ad
我正在尝试使用xmlstarlet(使用xpath)解析XML文件,但是出现语法错误,并且我不知道如何更正我的代码。 这是我的脚本: #!/bin/bash if [ $1=="author" ];
以下脚本旨在在目录中的所有文件上运行程序“senna”,并将每个文件的输出(保留输入文件名)写入另一个目录 for file in ./Data/in/*; do ./senna -iobta
我从 challengers.coffee 运行此代码,并收到错误 ActionView::Template::Error (SyntaxError: [stdin]:3:31:unexpected
我在 config.db.database; 行中有语法错误(意外的标记“.”)。这是我在文件中的代码 const config = require('../config/config') const
这一定很明显,但是我无法使它正常工作。我正在尝试传输应该用于构建$ classKey的对象,这反过来又导致删除所需的软件(amd64或i386)。好吧,这里的代码: $name = @("softwa
我正在使用 1.3.7 版学习 Grails,但我一直无缘无故地遇到以下语法错误: unexpected token: mapping @ line x, column y. 有一次,我通过运行“gr
我正在尝试找出这段Pascal代码的问题 function Factorial(n: integer): integer; begin if n = 0 then Result := 1
我是一名优秀的程序员,十分优秀!