例银行帐户的存取款线程设计(线程同步).doc

例 银行帐户的存取款线程设计。本例设计三个类，银行帐户类Account1、存款线程类Save1和取款线程类Fetch1。程序如下：一、未考虑同步问题（未锁定）class Account1 /帐户缓冲区 private String name; private int value; void put(int i) /欲存入金额i value = value + i; /存入时,value值增加 int get(int i) /欲取金额i,返回实际取到金额 if (valuei) value = value - i; /取走时,value值减少 else /帐户金额不够所取时 i = value; value = 0; /取走全部所余金额 return i; int howmatch() /查看帐户上现有金额 return value; class Save1 extends Thread /存款线程 private Account1 a1; private int amount; public Save1(Account1 a1,int amount) this.a1 = a1; this.amount = amount; public void run() int k = a1.howmatch(); try sleep(1); /花费时间 catch(InterruptedException e) System.out.println(e); a1.put(amount); System.out.println(现有+k+, 存入+amount+ , 余额+a1.howmatch();class Fetch1 extends Thread /取款线程 private Account1 a1; private int amount; public Fetch1(Account1 a1,int amount) this.a1 = a1 ; this.amount = amount; public void run() int k = a1.howmatch(); try sleep(1); /花费时间 catch(InterruptedException e) System.out.println(e); System.out.println(现有+k+, 取走+a1.get(amount)+, 余额+a1.howmatch(); public static void main (String args) Account1 a1 = new Account1(); (new Save1(a1,100).start(); (new Save1(a1,200).start(); (new Fetch1(a1,500).start(); 程序运行结果：现有0, 存入100, 余额100现有0, 存入200, 余额300现有0, 取走300, 余额01) SynchronizedSynchronized锁定一段代码，称为创建一个代码临界区，使得线程必须等候特定资源的所有权。当第一个线程执行这段代码时，它获取特定的对象的所有权，即拥有该对象的锁。此时，如果有第二个线程对同一个对象也要执行这段代码时，它试图获取该对象的所有权，但因该对象已被锁定，则第二个线程必须等待，直到锁被释放为止。第一个线程执行完后，自动释放了锁，接下去第二个线程获得锁并可运行。这样就形成了多个线程对同一个对象的“互斥”使用方式，该对象称为“同步对象”。这种锁定方式是针对某个特定对象而言的。如果有两个线程同时对两个不同的对象进行操作，则没有锁定，它们可以同时进入代码的临界区 二、 带锁定的存取款线程设计。class Save2 extends Thread /存款线程 private Account1 a1; private int amount; public Save2(Account1 a1,int amount) this.a1 = a1; this.amount = amount; public void run() synchronized (a1) /锁定帐户对象 int k = a1.howmatch(); try sleep(1); /花费时间 catch(InterruptedException e) System.out.println(e); a1.put(amount); System.out.println(现有+k+, 存入+amount+ , 余额+a1.howmatch(); public static void main (String args) Account1 a1 = new Account1(); (new Save2(a1,100).start(); (new Save2(a1,200).start(); (new Fetch2(a1,500).start(); class Fetch2 extends Thread /取款线程 private Account1 a1; private int amount; public Fetch2(Account1 a1,int amount) this.a1 = a1 ; this.amount = amount; public void run() synchronized (a1) /锁定帐户对象 int k = a1.howmatch(); try sleep(1); /花费时间 catch(InterruptedException e) System.out.println(e); S