done

Author: CarlosGuzman01

BankAccount.java

@@ -0,0 +1,63 @@
+import java.util.concurrent.locks.Condition;
+import java.util.concurrent.locks.Lock;
+import java.util.concurrent.locks.ReentrantLock;
+
+public class BankAccount {
+    
+    private double balance;
+    private Lock balanceChangeLock;
+    private Condition sufficientFundsCondition;
+    
+    public BankAccount(){
+        balance = 0;
+        balanceChangeLock =  new ReentrantLock();
+        sufficientFundsCondition = balanceChangeLock.newCondition();
+    }
+
+    public void deposit(double amount){
+        
+        balanceChangeLock.lock();
+        try{
+
+        System.out.print("Depositing " + amount);
+        double newBalance = balance + amount;
+        System.out.println(", new balance is " + newBalance);
+        balance = newBalance;
+        sufficientFundsCondition.signalAll();
+
+        }catch(Exception exception){
+
+        }finally{
+            balanceChangeLock.unlock();
+        }
+        
+    }
+
+    public void withdraw(double amount){
+
+        balanceChangeLock.lock();
+        try{
+
+            while (balance < amount) {
+                sufficientFundsCondition.await();
+                
+            }
+
+        System.out.print("Withdrawing " + amount);
+        double newBalance = balance - amount;
+        System.out.println(", new balance is " +  newBalance);
+        balance = newBalance;
+
+        }catch(Exception exception){
+
+        }finally{
+            balanceChangeLock.unlock();
+        }
+        
+    }
+
+    public double getBalance(){
+        return balance;
+    }
+
+}

BankAccountThreadRunner.java

@@ -0,0 +1,24 @@
+public class BankAccountThreadRunner{
+
+    public static void main(String[] args) {
+
+        BankAccount account = new BankAccount();
+        final double AMOUNT = 100;
+        final int REPETITIONS = 100;
+        final int THREADS = 100;
+
+        for(int i = 1; i <= THREADS; i++){
+           
+            DepositRunnable deposit = new DepositRunnable(account, AMOUNT, REPETITIONS);
+
+            WithdrawRunnable withdraw = new WithdrawRunnable(account, AMOUNT, REPETITIONS);
+
+            Thread depositThreat = new Thread(deposit);
+            Thread withdrawThread = new Thread(withdraw);
+
+            depositThreat.start();
+            withdrawThread.start();
+        }
+        
+    }
+}

DepositRunnable.java

@@ -0,0 +1,27 @@
+public class DepositRunnable implements Runnable{
+
+    private static final int DELAY = 1;
+    private BankAccount account;
+    private double amount;
+    private int count;
+
+    public DepositRunnable(BankAccount anAccount, double anAmount, int aCount){
+        account = anAccount;
+        amount = anAmount;
+        count = aCount;
+    }
+
+    @Override
+    public void run() {
+        try{
+            for(int i = 1; i <= count; i++){
+                account.deposit(amount);
+                Thread.sleep(DELAY);
+            }
+        }
+        catch (InterruptedException exception){
+
+        }
+    }
+
+}

WithdrawRunnable.java

@@ -0,0 +1,29 @@
+public class WithdrawRunnable implements Runnable {
+
+    private static final int DELAY = 1;
+    private BankAccount account;
+    private double amount;
+    private int count;
+
+
+    public WithdrawRunnable(BankAccount anAccount, double anAmount, int aCount){
+        account = anAccount;
+        amount = anAmount;
+        count = aCount;
+    }
+
+    @Override
+    public void run() {
+        
+        try{
+            for(int i = 1; i <= count; i++){
+                account.withdraw(amount);
+                Thread.sleep(DELAY);
+            }
+        }
+        catch(InterruptedException exception){}
+
+
+    }
+    
+}