 |
|
|
|
这种类型的保护被称为互斥锁。某个时间只能有一个线程读取或修改这个数据值。在对文件尤其是信息数据库进行处理时，读取的数据总是多于写数据，根据这个情况，可以简化程序。下面举一例，假设有一个雇员信息的数据库，其中包括雇员的地址和电话号码等信息，有时要进行修改，但要更多的还是读数据，因此要尽可能防止数据被破坏或任意删改。我们引入前面互斥锁的概念，允许一个读取锁（red lock）和写入锁（write lock）,可根据需要确定有权读取数据的人员，而且当某人要写数据时，必须有互斥锁，这就是信号标志的概念。信号标志有两种状态，首先是empty()状态，表示没有任何线程正在读或写，可以接受读和写的请求，并且立即提供服务；第二种状态是reading()状态，表示有线程正在从数据库中读信息，并记录进行读操作的线程数，当它为0时，返回empty状态，一个写请求将导致这个线程进入等待状态。
只能从empty状态进入writing状态，一旦进入writing状态后，其它线程都不能写操作，任何写或读请求都必须等到这个线程完成写操作为止，而且waiting状态中的进程也必须一直等到写操作结束。完成操作后，返回到empty状态，发送一个通知信号，等待的线程将得到服务。
下面实现了这个信号标志
class Semaphore{
final static int EMPTY=0;
final static int READING=1;
final static int WRITING=2;
protected int state=EMPTY;
protected int readCnt=0;
public synchronized void readLock(){
if(state==EMPTY){
state=READING;
}
else if(state==READING){
}
else if(state==WRITING){
while(state==WRITING){
try {wait();}
catch(InterruptedException e){;}
}
state=READING;
}
readCnt++;
return;
}
public synchronized void writeLock(){
if(state==EMPTY){
state=WRITING;
}
else{
while(state!=EMPTY){
try {wait();}
catch(InterruptedException e) {;}
}
}
}
public synchronized void readUnlock(){
readCnt--;
if(readCnt==0){
state=EMPTY;
notify();
}
}
public synchronized void writeUnlock(){
state=EMPTY;
notify();
}
相关文章 推荐文章
2008-5-9
