import java.util.concurrent.Semaphore;
public class ReadWriteLock {
private int count = 0;
public void readLock() throws InterruptedException {
readSemaphore.acquire();
if(count == 0){
writeSemaphore.acquire();
}
count=count+1;
readSemaphore.release();
}
public void readUnLock() throws InterruptedException {
readSemaphore.acquire();
count=count-1;
if(count == 0){
writeSemaphore.release();
}
readSemaphore.release();
}
public void writeLock() throws InterruptedException {
writeSemaphore.acquire();
}
public void writeUnlock(){
writeSemaphore.release();
}
}
Test code, not rigorous enough, just have a look
import org.junit.Test;
public class ReadWriteLockTest {
String test = “In Thread 1”;
@Test
public void testRead() throws Exception {
ReadWriteLock readWriteLock = new ReadWriteLock();
Thread thread1 = new Thread();
try {
readWriteLock.readLock();
System.out.println(test);
Thread.sleep(6000);
readWriteLock.readUnLock();
} catch (Exception e) {
e.printStackTrace();
}
Thread thread2 = new Thread();
try {
readWriteLock.readLock();
test=”In Thread 2”;
System.out.println(test);
Thread.sleep(4000);
readWriteLock.readUnLock();
} catch (Exception e) {
e.printStackTrace();
}
Thread t3 = new Thread();
try {
readWriteLock.writeLock();
test =”In Thread 3”;
System.out.println(test);
readWriteLock.writeUnlock();
} catch (Exception e) {
e.printStackTrace();
}
thread1.start();
thread2.start();
thread3.start();
thread3.join();
}
@Test
public void testWrite() throws Exception {
ReadWriteLock readWriteLock = new ReadWriteLock();
Thread thread1 = new Thread();
try {
readWriteLock.readLock();
System.out.println(test);
readWriteLock.readUnLock();
} catch (Exception e) {
e.printStackTrace();
}
Thread thread2 = new Thread();
try {
readWriteLock.readLock();
System.out.println(test);
readWriteLock.readUnLock();
} catch (InterruptedException e) {
e.printStackTrace();
}
Thread thread3 = new Thread();
try {
readWriteLock.writeLock();
test = “In Write Thread 3;
System.out.println(test);
Thread.sleep(2000);
readWriteLock.writeUnlock();
} catch (InterruptedException e) {
e.printStackTrace();
}
thread3.start();
thread1.start();
thread2.start();
thread2.join();
}
}
-Can you write the report describing this code?