最開始打算用semaphore實(shí)現(xiàn),
sem_t waitNonEmpty;
int empty=0;
sem_init(&waitNonEmpty, 1, empty); /*初始化信號(hào)量*/
sem_wait(&waitNonEmpty); /*是否有"非空資源"*/
sem_post(&waitNonEmpty); /*生成一個(gè)"非滿資源"*/
sem_destroy(&waitNonEmpty);
后來在fc3 redhat7.3下man了sem_init, 第二個(gè)參數(shù)int pshared
The pshared
argument indicates whether the semaphore is local to the current pro-
cess ( pshared is zero) or is to be shared between several processes (
pshared is not zero). LinuxThreads currently does not support process-
shared semaphores, thus sem_init always returns with error ENOSYS if
pshared is not zero.
最邪惡的現(xiàn)狀出來了, 這倆系統(tǒng)沒有實(shí)現(xiàn)sem的進(jìn)程間通信, 如果設(shè)置not zero, 會(huì)返回ENOSYS的錯(cuò)誤...
后來找了個(gè)redhat Enterprise 4 看了下文檔, 貌似又支持了....
做個(gè)記號(hào). 一會(huì)兒看看flock
fcntl 是唯一符合posix的文件鎖
結(jié)構(gòu)體flock的指針
：
struct flcok {
short int l_type; /* 鎖定的狀態(tài)*/
//這三個(gè)參數(shù)用于分段對文件加鎖，若對整個(gè)文件加鎖，則：l_whence=SEEK_SET,l_start=0,l_len=0;
short int l_whence;/*決定l_start位置*/
off_t l_start; /*鎖定區(qū)域的開頭位置*/
off_t l_len; /*鎖定區(qū)域的大小*/
pid_t l_pid; /*鎖定動(dòng)作的進(jìn)程*/
};
l_type 有三種狀態(tài):
F_RDLCK 建立一個(gè)供讀取用的鎖定
F_WRLCK 建立一個(gè)供寫入用的鎖定
F_UNLCK 刪除之前建立的鎖定
int fcntl(int fd, int cmd, struct flock *lock);
int cmd
//F_SETLKW對加鎖操作進(jìn)行阻塞，
//F_SETLK不對加鎖操作進(jìn)行阻塞，立即返回
當(dāng)使用F_SETLK宏，不進(jìn)行阻塞加鎖操作時(shí)。兩個(gè)進(jìn)程有對文件加鎖失敗的情況出現(xiàn)。
當(dāng)使用F_SETLKW宏，進(jìn)行阻塞加鎖操作時(shí)。兩個(gè)進(jìn)程沒有文件加鎖失敗的情況。但是根據(jù)進(jìn)程的輸出日志，可以明顯看出A進(jìn)程對文件操作時(shí)，B進(jìn)程停止對文件操作。
測試過程中打開文件使用O_RDWR | O_CREAT | O_APPEND模式，并對文件加寫鎖。鎖對打開文件沒有影響，但是對另一進(jìn)程加鎖和寫操作有影響。
加鎖對同一進(jìn)程中的多線程無效。同一進(jìn)程中的多線程對同一文件加鎖，后加鎖的線程會(huì)覆蓋前一個(gè)線程加的文件鎖。
fcntl文檔中寫到，一個(gè)進(jìn)程對一個(gè)文件的區(qū)域只能加一個(gè)類型的鎖
實(shí)現(xiàn)代碼如下:
//filelock.h
#ifndef __FILE_LOCK_HPP__
#define __FILE_LOCK_HPP__
#ifdef __cplusplus
extern "C" {
#endif
int file_lock(int fd);
int file_unlock(int fd);
#ifdef __cplusplus
}
#endif
#endif //__FILE_LOCK_HPP__
------------------------華麗分割線-----------------------------
//filelock.cpp
#include <fcntl.h>
#include <unistd.h>
#include "filelock.h";
int file_lock(int fd){
struct flock s_flock;
s_flock.l_type = F_WRLCK;
s_flock.l_whence = SEEK_SET;
s_flock.l_start = 0;
s_flock.l_len = 0;
s_flock.l_pid = getpid();
//F_SETLKW對加鎖操作進(jìn)行阻塞，
//F_SETLK不對加鎖操作進(jìn)行阻塞，立即返回
return fcntl(fd, F_SETLKW, &s_flock);
}
int file_unlock(int fd){
return fcntl(fd, F_SETLKW, F_UNLCK);
}
---------------------------------華麗的分割線--------------------------
test.cpp
#include "filelock.h"
#include <sys/types.h>
#include <sys/stat.h>
#include <fcntl.h>
#include <unistd.h>
#include <stdio.h>
#include <stdlib.h>
#include <sys/wait.h>
#include <errno.h>
int main(int argc,char *argv[]) {
int pid = -1;
int i = 5;
while(i--){
if ((pid = fork()) < 0) { //fork出錯(cuò)
puts("fork1 error");
} else if (pid > 0) {//父進(jìn)程
sleep(5);
if (waitpid(pid, NULL, 0) < 0)
puts("waitpid error");
} else {//子進(jìn)程
sleep(1);
int li_file = 0;
int li_lck_st = -1;
li_file = open("tt.txt", O_WRONLY|O_CREAT, 0777);
if( li_file < 0 ) {
printf("file open error\n");
}
printf("li_file=[%d] pid=[%d]\n", li_file , getpid() );
li_lck_st = file_lock(li_file);
sleep(5);
printf("li_lck_st=%d pid =%d\n", li_lck_st, getpid() );
file_unlock(li_file);
close(li_file);
printf("close file pid=%d unlock\n", getpid());
return 0;
}
}
return 0;
}
------------------------------華麗分割線---------------------------
//makefile
#########################################################
#Project: test
#By: Khan.Lau
#Description: test
#########################################################
CC = gcc
CXX = g++
STRIP = strip
AR = ar
PROJ = $(shell pwd)
DLLPATH = $(shell find $(PROJ) -name *.so*)
LIBPATH = /usr
INCS = -I$(LIBPATH)/include \
-I$(PROJ)/src/inc \
-I$(PROJ)/src
CXXINCS = -I$(LIBPATH)/include \
-I$(LIBPATH)/include/c++/4.3 \
-I$(LIBPATH)/include/c++/4.3/backward \
-I$(PROJ)/src/inc \
-I$(PROJ)/src
CFLAGS = -g -Wall $(CXXINCS)
#
CONFIGURATION = release
#
BIN = test.exe
#LIB = lib/HuaWeiBsc.a
#包路徑
LIBS = -L$(PROJ)/lib \
-L$(LIBPATH)/lib -lz
SRCS = $(wildcard \
src/lib/*.cpp \
src/kernel/*.cpp)
OBJBINS = $(SRCS:.cpp=.o)
.c.o:
$(CC) -o $@ -c $< $(CFLAGS)
.cpp.o:
$(CXX) -o $@ -c $< $(CFLAGS)
COLORH=echo -en "\033[1;32;40m"
COLORN=echo -en "\033[m"
all : $(BIN)
$(BIN) : $(OBJBINS)
$(CXX) -o $(CONFIGURATION)/$(BIN) $(OBJBINS) $(LIBS)
@$(COLORN)
$(shell echo "$(BIN) build complete.")
#$(LIB) : $(OBJBINS)
# ar rc $(LIB) $(OBJBINS)
clean :
rm -f $(OBJBINS)
rm -f $(BIN)
-----------------------------華麗分割線--------------------------
測試環(huán)境 ubuntu 8.10, redhat 7.3, redhat fc3 redhat enterprise 4.6
結(jié)果:
khan@khan-laptop:~/project/filelock/release$ ./test.exe
li_file=[3] pid=[10959]
li_lck_st=0 pid =10959
close file pid=10959 unlock
li_file=[3] pid=[10961]
li_lck_st=0 pid =10961
close file pid=10961 unlock
li_file=[3] pid=[10964]
li_lck_st=0 pid =10964
close file pid=10964 unlock
li_file=[3] pid=[10966]
li_lck_st=0 pid =10966
close file pid=10966 unlock
li_file=[3] pid=[10969]
li_lck_st=0 pid =10969
close file pid=10969 unlock