SerialExecution.java

//Manish Mahalwal 2016054
//Raj Kamal yadav 2016076

import java.io.IOException;
import java.io.Serializable;
import java.util.ArrayList;
import java.util.Random;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
import java.util.concurrent.TimeUnit;
import java.util.concurrent.locks.Lock;
import java.util.concurrent.locks.ReentrantLock;

class DatabaseSerial
{
	ArrayList<Flight> Pl;
	ArrayList<Passenger> PL;
	RockLockS lock = new RockLockS();
	public DatabaseSerial(){
		Pl=new ArrayList<>();
		
		PL=new ArrayList<>();
		Pl.add(new Flight("1"));
		Pl.add(new Flight("2"));
		Pl.add(new Flight("3"));
		Pl.add(new Flight("4"));
		Pl.add(new Flight("5"));

	}
	public void add(Flight t,Passenger a){
		int y=Integer.parseInt(t.id)-1;
		this.Pl.get(y).Plist.add(a);
		  
		
	}
	public void add_f(Flight flight, Passenger a) {
		
		a.Book_flight_list.add(flight);
		
		int psa=search(a.id);
		if(psa<0){
			PL.add(a);
		}
	}
	public void delete(Flight t,Passenger s){
		int yes=0;
		for(int i=0;i<t.Plist.size();i++)
		{
			if(t.Plist.get(i).id.equals(s.id)){
				t.Plist.remove(i);
				yes=1;				
			}
		}
		if(yes==0){
			//System.out.println("No Passenger with the given name exist on flight");
		}
	}
	public void delete_f(Flight t,Passenger s){
	
		for(int i=0;i<t.Plist.size();i++)
		{
			if(s.Book_flight_list.get(i).id.equals(t.id)){
				s.Book_flight_list.remove(i);					
			}
		}
		
	}
	public int search_on_flight(Flight t,String s){
		for(int i=0;i<t.Plist.size();i++)
		{
			if(t.Plist.get(i).id.equals(s)){
				return i;
				
				
			}
		}
		return -1;
	}
	public int search(String s){
		for(int i=0;i<PL.size();i++)
		{
			if(PL.get(i).id.equals(s)){
				return i;
				
				
			}
		}
		return -1;
	}
	public void replace(Passenger h,Flight a,Flight b){
		for(int l=0;l<h.Book_flight_list.size();l++){
			if(h.Book_flight_list.get(l).id.equals(a.id)){
				h.Book_flight_list.remove(l);
			}
		}
		h.Book_flight_list.add(b);
	}
	public  void f_lock() throws InterruptedException{	

		    	for(int y=0;y<this.Pl.size();y++){
		    		
		    		//System.out.println("FLight Id  : "+ this.Pl.get(y).id);
		    		//System.out.println("Reserved Passngers : ");
		    		for(int h=0;h<this.Pl.get(y).Plist.size();h++){
		    			//System.out.println(this.Pl.get(y).Plist.get(h).id);
		    		}
		    	}
		
	}	
	
}

class Flight  {
	String id;
	ArrayList<Passenger> Plist;
	Lock lock = new ReentrantLock();
	public Flight(String t){
		id=t;
		Plist=new ArrayList<>();
	}

	public  void c_lock(DatabaseSerial dB, Passenger t2) throws InterruptedException{	

		    	dB.delete(this, t2);

		
	}
	public void h_lock(DatabaseSerial db,Passenger e) throws InterruptedException {

		    	
		    	db.delete(this, e);

	}
	public void i_lock(DatabaseSerial dB, Passenger e) throws InterruptedException {


		    	
		    	dB.add(this, e);

	
	}
}
class Passenger implements Serializable {
	String id;
	ArrayList<Flight> Book_flight_list;
	Lock lock=new ReentrantLock();
	public Passenger(String t){
		id=t;
		Book_flight_list=new ArrayList<>();
		
	}



	public void d_lock(DatabaseSerial db, Flight flight) throws InterruptedException {

		    	db.delete_f(flight, this); 

	}
	public void e_lock(DatabaseSerial db,int e) throws InterruptedException {

		    	//System.out.println("printing it "+e+"  "+db.PL.get(e).Book_flight_list.size());
		    	
		    	for(int i=0;i<db.PL.get(e).Book_flight_list.size();i++){
		    		//System.out.println(db.PL.get(e).Book_flight_list.get(i).id);
		    	}

	}
	public void g_lock(DatabaseSerial db,Flight a,Flight b) throws InterruptedException {

		 db.replace(this, a, b);

	}
	
	
}
class RockLockS {
	
	int s_status=0;	
	//1 is already locked
	//0 object can obtain lock
	public void lock(){
		if(s_status==1){
			while(s_status==1){
				//System.out.println("x_lock already acquired");
			}
			//System.out.println("s_lock acquired");
			s_status = 1;
		}
		else
			s_status = 1;
	}
	public void unlock(){
		if(s_status==1){
			s_status=0;
		}
	}

	
}
class TransactionsSerial implements Runnable {
	DatabaseSerial DB;
	int trans_id;
	String flight1, flight2, passenger;
	int timestamp=0;
	
	public TransactionsSerial(DatabaseSerial c,int id) throws ClassNotFoundException, IOException{
		this.trans_id = id;
		DB=c;

	}
	public TransactionsSerial(DatabaseSerial c,String f,String p, int id) {
		this.trans_id = id;
		this.flight1 = f;
		this.passenger = p;
		DB=c;
	}
	
	public TransactionsSerial(DatabaseSerial c,String f1,String f2,String p, int id) {
		this.trans_id = id;
		this.flight1 = f1;
		this.flight2 = f2;
		this.passenger = p;
		
		DB=c;

	}
	
	
	public TransactionsSerial(DatabaseSerial c,String p, int id) {
		this.trans_id = id;
		this.passenger = p;
		DB=c;

	}
	
	public void reserve(String f,String p){
		int f_id=Integer.parseInt(f)-1;
		int wh=DB.search(p);		
		if(f_id<5&& f_id>=0 ){
	
			if(wh>=0){
				DB.lock.lock();
				DB.add_f(DB.Pl.get(f_id), DB.PL.get(wh)); 
				DB.add(DB.Pl.get(f_id), DB.PL.get(wh));
				DB.lock.unlock();

			}
			else{
				////System.out.println("therajskldfdsh");

				DB.lock.lock();
				Passenger t_n=new Passenger(p);

					DB.add_f(DB.Pl.get(f_id), t_n); 
					DB.add(DB.Pl.get(f_id),t_n);
					DB.lock.unlock();
			}	
		}		
		else{
			//System.out.println("Invalid Flight ID here");
		}
		
	}
	public void cancel(String f,String p) {
		int f_id=Integer.parseInt(f)-1;
		int wh=DB.search(p);		
		if(f_id<5&& f_id>=0 && wh>=0){			

				DB.lock.lock();
				DB.delete_f(DB.Pl.get(f_id), DB.PL.get(wh));
				DB.delete(DB.Pl.get(f_id), DB.PL.get(wh));
				DB.lock.unlock();
			
		}		
		else{
			//System.out.println("Invalid Flight ID");
		}
		
	}
	public void my_flights(String p){
		//returns the set of flights on which passenger i has a reservation		
		int wh=DB.search(p);
		
		if(wh>=0){
			//Lock a=new ReentrantLock();
			DB.lock.lock();
	    	for(int i=0;i<DB.PL.get(wh).Book_flight_list.size();i++){
	    		//System.out.println(DB.PL.get(wh).Book_flight_list.get(i).id);
	    	}
	    	DB.lock.unlock();

		
			}		
			
	}
	public void total_reservations(){
		//returns the sum total of all reservations on all flights.
		DB.lock.lock();
	    	for(int y=0;y<DB.Pl.size();y++){
	    		
	    		//System.out.println("FLight Id  : "+ DB.Pl.get(y).id);
	    		//System.out.println("Reserved Passngers : ");
	    		for(int h=0;h<DB.Pl.get(y).Plist.size();h++){
	    			//System.out.println(DB.Pl.get(y).Plist.get(h).id);
	    		}
	    	}
	    DB.lock.unlock();

	}
	public void transfer(String f1,String f2,String p){
		//transfer passenger i from flight F1 to F2. This transaction should have no impact if the passenger is not found in F1 or there is no room in F2.
		int f_id1=Integer.parseInt(f1)-1;
		int f_id2=Integer.parseInt(f2)-1;
		int wh=DB.search(p);		
		if(f_id1<5&& f_id1>=0&&f_id2<5&& f_id2>=0 && wh>=0){			
			DB.lock.lock();
		    	DB.replace(DB.PL.get(wh),DB.Pl.get(f_id1),DB.Pl.get(f_id2));
		    	DB.delete(DB.Pl.get(f_id1), DB.PL.get(wh));
		    	DB.add(DB.Pl.get(f_id2), DB.PL.get(wh));
		    	
		    DB.lock.unlock();
				
		}		
		else{
			//System.out.println("Invalid Flight ID");
		}
	
		
		
	}
	@Override
	public void run() {
		if(this.trans_id==1)
		{
			this.reserve(this.flight1, this.passenger);
			
		}
		else if(this.trans_id==2)
		{
			this.cancel(this.flight1, this.passenger);
		}
		else if(this.trans_id==3)
		{
			this.my_flights(this.passenger);
		}
		else if(this.trans_id==4)
		{
			this.total_reservations();
		}
		else if(this.trans_id==5)
		{
			this.transfer(this.flight1, this.flight2, passenger);
		}	
	}
}
public class SerialExecution {
	public static void main(String[] args) throws IOException, ClassNotFoundException, InterruptedException{
		//Database DB=new Database();	
		Random ran = new Random(); 
		ArrayList<TransactionsSerial> ts=new ArrayList<>();
		DatabaseSerial DB=new DatabaseSerial();	
		int x = 50;
		for(int i=0;i<x;i++){
			int y = ran.nextInt(5);
			//System.out.println("Transaction type: " + (1+y));
			if(y==0)
			{

				int fight = 1 + ran.nextInt(5);
				int pass= 1+ ran.nextInt(3);
				//System.out.println("To reserve passenger "+pass+" in the flight "+fight);
				
				TransactionsSerial R=new TransactionsSerial(DB,Integer.toString(fight),Integer.toString(pass), 1);
				ts.add(R);
				
				
			}
			else if (y==1){
				int fight=1+ran.nextInt(5);
				int pass=1+ran.nextInt(5);
				//System.out.println("To cancel passenger "+pass+" from the flight "+fight);

				TransactionsSerial R=new TransactionsSerial(DB,Integer.toString(fight),Integer.toString(pass), 2);
				ts.add(R);
			}
			else if(y==2){
				int pass=1+ran.nextInt(5);
				//System.out.println("Show all the flights of the passenger " + pass);
				TransactionsSerial R=new TransactionsSerial(DB,Integer.toString(pass), 3);
				ts.add(R);
			}
			else if(y==3){
				TransactionsSerial R=new TransactionsSerial(DB,4); 
				ts.add(R);
				
				
			}
			else if(y==4){
				int fight1 = 1 + ran.nextInt(5);
				int fight2 = 1 + ran.nextInt(5);
				int pass = 1 + ran.nextInt(5);
				//System.out.println("To transfer passenger "+pass+" from the flight "+fight1+" to the flight "+fight2);

				TransactionsSerial R=new TransactionsSerial(DB,Integer.toString(fight1),Integer.toString(fight2),Integer.toString(pass), 5);
				ts.add(R);

			}
		}

		long startTime = System.currentTimeMillis();
		ExecutorService exec = Executors.newFixedThreadPool(1);
		
		for(int i=0;i<ts.size();i++){
			long startTime2 = System.currentTimeMillis();
			exec.submit(ts.get(i));
			long endTime2   = System.currentTimeMillis();
			long totalTime2 = endTime2 - startTime2;
			Thread.sleep(1);
		}
		if(!exec.isTerminated()) {
			exec.shutdown();
			exec.awaitTermination(10L,TimeUnit.SECONDS);}
		long endTime   = System.currentTimeMillis();
		long totalTime = endTime - startTime;
		System.out.println(totalTime);
	}
}