package concurrency.ch4;

import static org.junit.Assert.*;

import java.util.concurrent.CountDownLatch;
import java.util.concurrent.Executor;
import java.util.concurrent.Executors;
import java.util.concurrent.Semaphore;
import java.util.concurrent.TimeUnit;

import org.junit.Before;
import org.junit.Test;

public class WriterPriorityReaderWriterLightSwitchTest {
	private String mutableData = "Initial Value";
	private final LightSwitch readSwitch = new LightSwitch();
	private final LightSwitch writeSwitch = new LightSwitch();
	private final Semaphore mutex = new Semaphore(1);
	private final Semaphore noReaders = new Semaphore(1);
	private final Semaphore noWriters = new Semaphore(1);
	private final CountDownLatch latch = new CountDownLatch(31);
	
	private Executor executor = Executors
			.newFixedThreadPool(Runtime.getRuntime().availableProcessors());

	@Test
	public void test() throws InterruptedException {
		for(int i = 0; i < 20; i++){
			final int index = i;
			executor.execute(new Reader());
			if(i%2 == 0) executor.execute(new Writer(index));
		}
		
		latch.countDown();
		latch.await(5, TimeUnit.SECONDS);
	}
	
	private class Reader implements Runnable {

		public void run() {
			
			noReaders.acquireUninterruptibly();
			readSwitch.lock(noWriters);
			noReaders.release();
			
			System.out.println(mutableData);
			
			readSwitch.unlock(noWriters);
			
			latch.countDown();
		}
		
	}
	
	private class Writer implements Runnable{
		private final int id;
		
		Writer(final int id){
			this.id = id;
		}
		
		public void run() {
			
			writeSwitch.lock(noReaders);
			noWriters.acquireUninterruptibly();
			
			mutableData = "Writer " + id;
			
			noWriters.release();
			writeSwitch.unlock(noReaders);
			
			latch.countDown();
		}
	}

}

@@ -529,59 +529,8 @@
 ();%0A
-%09private final Semaphore mutex = new Semaphore(1);%0A
 %09pri

remove dead code from 4.2.7 solution