前の質問の回答で sayuri さんが言いたかったのは、ロックする時と解除する時とで
fp
(というか file descriptor) が違う点が問題、ということだと思います。
以下のように flock()
でも問題ないと思います。
#include <stdio.h>
#include <stdlib.h>
#include <unistd.h>
#include <sys/file.h>
#include <pthread.h>
#define N 2
static FILE *fp0;
static void *test0(void *parm)
{
int n = *(int *) parm;
if ((fp0 = fopen("test.txt", "a+")) == NULL) {
perror("fopen");
exit(1);
}
if (flock(fileno(fp0), LOCK_EX | LOCK_NB) != 0) {
perror("flock");
exit(1);
}
return NULL;
}
static void *test1(void *parm)
{
int n = *(int *) parm;
FILE *fp;
if (flock(fileno(fp0), LOCK_UN | LOCK_NB) != 0) {
perror("flock");
exit(1);
}
if ((fp = fopen("test.txt", "a+")) == NULL) {
perror("fopen");
exit(1);
}
if (flock(fileno(fp), LOCK_EX | LOCK_NB) != 0) {
perror("flock");
exit(1);
}
fclose(fp);
return NULL;
}
int main(void)
{
pthread_t thr[N];
pthread_attr_t attr[N];
int n[N];
for (int i = 0; i < N; i++)
n[i] = i;
pthread_attr_init(&attr[0]);
pthread_create(&thr[0], &attr[0], test0, &n[0]);
sleep(1);
pthread_attr_init(&attr[1]);
pthread_create(&thr[1], &attr[1], test1, &n[1]);
for (int i = 0; i < N; i++) {
void *r;
pthread_join(thr[i], &r);
}
return 0;
}
test0()
側スレッドで fopen()
した fp0
を、test1()
側スレッドに渡す必要があります。
この fp0
を放置すると、何度もスレッドが落ちた場合に fclose()
されない FILE *
がどんどん残っていってしまいます。従って強制解除と同時に fclose()
も必要になるでしょうから、どのみち test1()
側スレッドに渡す必要はあるので、この点は問題にはならないと思っています。