Student library stimulation

Author: Ashfaqbs

Concurrency_Multithreading_and_Parallel_Computing_in_Java/bin/org/ashfaq/dev/problems/StudentLibrarySimulation/App.class

@@ -0,0 +1,35 @@
+package org.ashfaq.dev.problems.StudentLibrarySimulation;
+
+import java.util.concurrent.ExecutorService;
+import java.util.concurrent.Executors;
+
+public class App {
+
+	public static void main(String[] args) throws InterruptedException {
+
+		Student[] students = null;
+		Book[] books = null;
+		ExecutorService executorService = Executors.newFixedThreadPool(Constants.NUM_OF_STUDENTS);
+
+		try {
+			students = new Student[Constants.NUM_OF_STUDENTS];
+			books = new Book[Constants.NUM_OF_BOOKS];
+
+			for (int i = 0; i < Constants.NUM_OF_BOOKS; i++) {
+				books[i] = new Book(i + 1);
+			}
+
+			for (int i = 0; i < Constants.NUM_OF_STUDENTS; i++) {
+				students[i] = new Student(i + 1, books);
+				executorService.execute(students[i]);
+			}
+
+		} catch (Exception e) {
+			// TODO: handle exception
+		} finally {
+			executorService.shutdown();
+		}
+
+	}
+
+}

Concurrency_Multithreading_and_Parallel_Computing_in_Java/bin/org/ashfaq/dev/problems/StudentLibrarySimulation/Book.class

@@ -0,0 +1,31 @@
+package org.ashfaq.dev.problems.StudentLibrarySimulation;
+
+import java.util.concurrent.TimeUnit;
+import java.util.concurrent.locks.Lock;
+import java.util.concurrent.locks.ReentrantLock;
+
+public class Book {
+
+	private int id;
+	private Lock lock;
+
+	public Book(int id) {
+		this.id = id;
+		this.lock = new ReentrantLock();
+	}
+
+	public void read(Student student) throws InterruptedException {
+//		lock.tryLock(10, TimeUnit.MILLISECONDS);
+		lock.lock();
+		System.out.println(student + " starts reading " + this);
+		Thread.sleep(2000);
+		lock.unlock();
+		System.out.println(student + " has just finsnished reading " + this);
+	}
+
+	@Override
+	public String toString() {
+		return "Book-" + this.id;
+	}
+
+}

Concurrency_Multithreading_and_Parallel_Computing_in_Java/bin/org/ashfaq/dev/problems/StudentLibrarySimulation/Constants.class

@@ -0,0 +1,11 @@
+package org.ashfaq.dev.problems.StudentLibrarySimulation;
+
+public class Constants {
+	private Constants() {
+		// TODO Auto-generated constructor stub
+	}
+
+	public static final int NUM_OF_STUDENTS = 5;
+	public static final int NUM_OF_BOOKS = 7;
+//	public static final int SIMULATION_RUNNING_TIME = 1000;
+}

Concurrency_Multithreading_and_Parallel_Computing_in_Java/bin/org/ashfaq/dev/problems/StudentLibrarySimulation/Student.class

@@ -0,0 +1,58 @@
+package org.ashfaq.dev.problems.StudentLibrarySimulation;
+
+import java.util.Random;
+
+public class Student implements Runnable {
+	private int id;
+	private Book[] books;
+
+	private Random random;
+
+	public Student(int id, Book[] books) {
+		this.id = id;
+		this.books = books;
+		this.random = new Random();
+	}
+
+	@Override
+	public String toString() {
+		return "Student [id=" + id + "]";
+	}
+
+	public int getId() {
+		return id;
+	}
+
+	public void setBooks(Book[] books) {
+		this.books = books;
+	}
+
+	public void setId(int id) {
+		this.id = id;
+	}
+
+	public Book[] getBooks() {
+		return books;
+	}
+
+	@Override
+	public void run() {
+		while (true) {
+			int bookId = random.nextInt(Constants.NUM_OF_BOOKS);
+			try {
+				books[bookId].read(this);
+			} catch (InterruptedException e) {
+				// TODO Auto-generated catch block
+				e.printStackTrace();
+			}
+		}
+	}
+	
+	
+	
+	
+	
+	
+	
+
+}