Question
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();
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 verbally write the report describing this code and its solution in detail?
Step by Step Solution
There are 3 Steps involved in it
Step: 1
Get Instant Access to Expert-Tailored Solutions
See step-by-step solutions with expert insights and AI powered tools for academic success
Step: 2
Step: 3
Ace Your Homework with AI
Get the answers you need in no time with our AI-driven, step-by-step assistance
Get Started