Thread Deadlock

slgobinath · slgobinath · commit 51b9870e6baf · 2015-06-10T22:28:03.000+05:30
diff --git a/threaddeadlock/Account.java b/threaddeadlock/Account.java
@@ -0,0 +1,25 @@
+public class Account {
+	private final String name;
+	private double balance;
+
+	public Account(String name) {
+		this.name = name;
+	}
+
+	public void withdraw(double amount) {
+		this.balance -= amount;
+	}
+
+	public void deposit(double amount) {
+		this.balance += amount;
+	}
+
+	public double getBalance() {
+		return this.balance;
+	}
+
+	@Override
+	public String toString() {
+		return name;
+	}
+}
diff --git a/threaddeadlock/Main.java b/threaddeadlock/Main.java
@@ -0,0 +1,14 @@
+public class Main {
+	public static void main(String[] args) {
+		final Account accA = new Account("Acc 1");
+		final Account accB = new Account("Acc 2");
+		accA.deposit(1000.00);
+		accB.deposit(1000.00);
+
+		Transaction t1 = new Transaction("T01", accA, accB, 100.00);
+		Transaction t2 = new Transaction("T02", accB, accA, 500.00);
+
+		t1.start();
+		t2.start();
+	}
+}
diff --git a/threaddeadlock/Transaction.java b/threaddeadlock/Transaction.java
@@ -0,0 +1,29 @@
+public class Transaction extends Thread {
+	private final String id;
+	private final Account from;
+	private final Account to;
+	private final double amount;
+
+	public Transaction(String id, Account from, Account to, double amount) {
+		this.id = id;
+		this.from = from;
+		this.to = to;
+		this.amount = amount;
+	}
+
+	@Override
+	public void run() {
+		synchronized (from) {
+			from.withdraw(amount);
+			try {
+				Thread.sleep(500);
+			} catch (InterruptedException e) {
+			}
+			synchronized (to) {
+				to.deposit(amount);
+			}
+		}
+		System.out.println(from + " is released by " + id);
+		System.out.println(amount + "is transfered from " + from + " to " + to);
+	}
+}
diff --git a/threaddeadlock/fixed/Account.java b/threaddeadlock/fixed/Account.java
@@ -0,0 +1,25 @@
+public class Account {
+	private final String name;
+	private double balance;
+
+	public Account(String name) {
+		this.name = name;
+	}
+
+	public void withdraw(double amount) {
+		this.balance -= amount;
+	}
+
+	public void deposit(double amount) {
+		this.balance += amount;
+	}
+
+	public double getBalance() {
+		return this.balance;
+	}
+
+	@Override
+	public String toString() {
+		return name;
+	}
+}
diff --git a/threaddeadlock/fixed/Main.java b/threaddeadlock/fixed/Main.java
@@ -0,0 +1,14 @@
+public class Main {
+	public static void main(String[] args) {
+		final Account accA = new Account("Acc 1");
+		final Account accB = new Account("Acc 2");
+		accA.deposit(1000.00);
+		accB.deposit(1000.00);
+
+		Transaction t1 = new Transaction("T01", accA, accB, 100.00);
+		Transaction t2 = new Transaction("T02", accB, accA, 500.00);
+
+		t1.start();
+		t2.start();
+	}
+}
diff --git a/threaddeadlock/fixed/Transaction.java b/threaddeadlock/fixed/Transaction.java
@@ -0,0 +1,29 @@
+public class Transaction extends Thread {
+	private final String id;
+	private final Account from;
+	private final Account to;
+	private final double amount;
+
+	public Transaction(String id, Account from, Account to, double amount) {
+		this.id = id;
+		this.from = from;
+		this.to = to;
+		this.amount = amount;
+	}
+
+	@Override
+	public void run() {
+		synchronized (from) {
+			from.withdraw(amount);
+			try {
+				Thread.sleep(500);
+			} catch (InterruptedException e) {
+			}
+        }
+		synchronized (to) {
+			to.deposit(amount);
+		}
+		System.out.println(from + " is released by " + id);
+		System.out.println(amount + "is transfered from " + from + " to " + to);
+	}
+}
