package synch;/*** 这个程序展示了多线程如何安全地访问数据结构。* @version 1.31 2015-06-21* @author Cay Horstmann*/
public class SynchBankTest
{public static final int NACCOUNTS = 100;public static final double INITIAL_BALANCE = 1000;public static final double MAX_AMOUNT = 1000;public static final int DELAY = 10;public static void main(String[] args){Bank bank = new Bank(NACCOUNTS, INITIAL_BALANCE);for (int i = 0; i < NACCOUNTS; i++){int fromAccount = i;Runnable r = () -> {try{while (true){int toAccount = (int) (bank.size() * Math.random());double amount = MAX_AMOUNT * Math.random();bank.transfer(fromAccount, toAccount, amount);Thread.sleep((int) (DELAY * Math.random()));}}catch (InterruptedException e){}            };Thread t = new Thread(r);t.start();}}
}

package synch;import java.util.*;
import java.util.concurrent.locks.*;/*** 具有许多银行帐户的银行，使用锁序列化访问。* @version 1.30 2004-08-01* @author Cay Horstmann*/
public class Bank
{private final double[] accounts;private Lock bankLock;//锁对象private Condition sufficientFunds;/*** 构建银行。* @param n账户数量* @param 每个帐户的初始余额*/public Bank(int n, double initialBalance){accounts = new double[n];Arrays.fill(accounts, initialBalance);bankLock = new ReentrantLock();sufficientFunds = bankLock.newCondition();}/*** 把钱从一个账户转到另一个账户，再从一个账户转到另一个账户，再从另一个账户转到另一个账户* @param from the account to transfer from* @param to the account to transfer to* @param amount the amount to transfer*/public void transfer(int from, int to, double amount) throws InterruptedException{bankLock.lock();try{//锁对象的引用条件对象while (accounts[from] < amount)sufficientFunds.await();System.out.print(Thread.currentThread());//打印出线程号accounts[from] -= amount;System.out.printf(" %10.2f from %d to %d", amount, from, to);accounts[to] += amount;System.out.printf(" Total Balance: %10.2f%n", getTotalBalance());sufficientFunds.signalAll();}finally{bankLock.unlock();}}/*** 获取所有帐户余额的总和。* @return 总平衡*/public double getTotalBalance(){bankLock.lock();//加锁try{double sum = 0;for (double a : accounts)sum += a;return sum;}finally{bankLock.unlock();//解锁}}/*** 获取银行中的帐户数量。* @return 账户数量*/public int size(){return accounts.length;}
}

package synch2;import java.util.*;/*** A bank with a number of bank accounts that uses synchronization primitives.* @version 1.30 2004-08-01* @author Cay Horstmann*/
public class Bank
{private final double[] accounts;/*** Constructs the bank.* @param n the number of accounts* @param initialBalance the initial balance for each account*/public Bank(int n, double initialBalance){accounts = new double[n];Arrays.fill(accounts, initialBalance);}/*** Transfers money from one account to another.* @param from the account to transfer from* @param to the account to transfer to* @param amount the amount to transfer*/public synchronized void transfer(int from, int to, double amount) throws InterruptedException{while (accounts[from] < amount)wait();System.out.print(Thread.currentThread());accounts[from] -= amount;System.out.printf(" %10.2f from %d to %d", amount, from, to);accounts[to] += amount;System.out.printf(" Total Balance: %10.2f%n", getTotalBalance());notifyAll();}/*** Gets the sum of all account balances.* @return the total balance*/public synchronized double getTotalBalance(){double sum = 0;for (double a : accounts)sum += a;return sum;}/*** Gets the number of accounts in the bank.* @return the number of accounts*/public int size(){return accounts.length;}
}

package synch2;/*** This program shows how multiple threads can safely access a data structure,* using synchronized methods.* @version 1.31 2015-06-21* @author Cay Horstmann*/
public class SynchBankTest2
{public static final int NACCOUNTS = 100;public static final double INITIAL_BALANCE = 1000;public static final double MAX_AMOUNT = 1000;public static final int DELAY = 10;public static void main(String[] args){Bank bank = new Bank(NACCOUNTS, INITIAL_BALANCE);for (int i = 0; i < NACCOUNTS; i++){int fromAccount = i;Runnable r = () -> {try{while (true){int toAccount = (int) (bank.size() * Math.random());double amount = MAX_AMOUNT * Math.random();bank.transfer(fromAccount, toAccount, amount);Thread.sleep((int) (DELAY * Math.random()));}}catch (InterruptedException e){}};Thread t = new Thread(r);t.start();}}
}

class Cbank
{private static int s=2000;public   static void sub(int m){int temp=s;temp=temp-m;try {Thread.sleep((int)(1000*Math.random()));}catch (InterruptedException e)  {              }s=temp;System.out.println("s="+s);}}class Customer extends Thread
{public void run(){for( int i=1; i<=4; i++)Cbank.sub(100);}}
public class Thread3
{public static void main(String args[]){Customer customer1 = new Customer();Customer customer2 = new Customer();customer1.start();customer2.start();}
}

package lll;class Cbank
{private static int s=2000;public synchronized  static void sub(int m){int temp=s;temp=temp-m;try {Thread.sleep((int)(1000*Math.random()));}catch (InterruptedException e)  {              }s=temp;System.out.println("s="+s);}}class Customer extends Thread
{public void run(){for( int i=1; i<=4; i++)Cbank.sub(100);}}
public class Thread3
{public static void main(String args[]){Customer customer1 = new Customer();Customer customer2 = new Customer();customer1.start();customer2.start();}
}

package lll;public class Demo {public static void main(String[] args) {Runnable runnable = new MyThread();new Thread(runnable).start();new Thread(runnable).start();new Thread(runnable).start();}public static class MyThread implements Runnable{ private int tickets=10; public void run() { while(tickets>0){ System.out.println(Thread.currentThread().getName() + "窗口售：第" + tickets-- + "张票"); } } }
}