Java开拓多线程同步能力

副标题#e#

在编写一个类时，假如该类中的代码大概运行于多线程情况下，那么就要思量同步的问题。在Java中内置了语言级的同步原语－－synchronized，这也大大简化了Java中多线程同步的利用。 我们首先编写一个很是简朴的多线程的措施，是模仿银行中的多个线程同时对同一个储备账户举办存款、取款操纵的。

在措施中我们利用了一个简化版本的Account类，代表了一个银行账户的信息。在主措施中我们首先生成了1000个线程，然后启动它们，每一个线程都对John的账户举办存100元，然后顿时又取出100元。这样，对付John的账户来说，最终账户的余额应该是照旧1000元才对。然而运行的功效却超出我们的想像，首先来看看我们的演示代码：

class Account
{
　 String name; float amount;
　 public Account(String name, float amount)
　 {
　　 this.name = name;
　　 this.amount = amount;
　 }
　
　 public void deposit(float amt)
　 {
　　 float tmp = amount;
　　 tmp += amt;
　　 try
　　 {
　　　 Thread.sleep(100);
　　　 //模仿其它处理惩罚所需要的时间，好比刷新数据库等
　　 }
　　 catch (InterruptedException e)
　　 {
　　　 // ignore
　　 }
　　 amount = tmp;
　 }
　 public void withdraw(float amt)
　 {
　　 float tmp = amount;
　　 tmp -= amt;
　　 try
　　 {
　　　 Thread.sleep(100);
　　　 //模仿其它处理惩罚所需要的时间，好比刷新数据库等
　　 }
　　 catch (InterruptedException e)
　　 {
　　　 // ignore
　　 }
　　 amount = tmp;
　 }
　 public float getBalance()
　 {
　　 return amount;
　 }
}
public class AccountTest
{
　 private static int NUM_OF_THREAD = 1000;
　 static Thread[] threads = new Thread[NUM_OF_THREAD];
　 public static void main(String[] args)
　 {
　　 final Account acc = new Account("John", 1000.0f);
　　 for (int i = 0; i< NUM_OF_THREAD; i++)
　　 {
　　　 threads[i] = new Thread(new Runnable()
　　　 {
　　　　 public void run()
　　　　 {
　　　　　 acc.deposit(100.0f);
　　　　　 acc.withdraw(100.0f);
　　　　 }
　　　 }
　　 );
　　 threads[i].start();
　 }
　 for (int i=0; i<NUM_OF_THREAD; i++)
　 {
　　 try { threads[i].join();
　　 //期待所有线程运行竣事
　 }
　 catch (InterruptedException e)
　 {
　　 // ignore
　 }
}
System.out.println("Finally, John's balance is:" + acc.getBalance()); }}

#p#副标题#e#

留意，上面在Account的deposit和withdraw要领中之所以要把对amount的运算利用一个姑且变量首先存储，sleep一段时间，然后，再赋值给amount，是为了模仿真实运行时的环境。因为在真实系统中，账户信息必定是存储在耐久前言中，好比RDBMS中，此处的睡眠的时间相当于较量耗时的数据库操纵，最后把姑且变量tmp的值赋值给amount相当于把amount的窜改写入数据库中。运行AccountTest，功效如下（每一次功效城市差异）：

E:\java\exer\bin>java AccountTest
Finally, John's balance is:3900.0
E:\java\exer\bin>java AccountTest
Finally, John's balance is:4900.0
E:\java\exer\bin>java AccountTest
Finally, John's balance is:4700.0
E:\java\exer\bin>java AccountTest
Finally, John's balance is:3900.0
E:\java\exer\bin>java AccountTest
Finally, John's balance is:3900.0
E:\java\exer\bin>java AccountTest
Finally, John's balance is:5200.0

为什么会呈现这样的问题？这就是多线程中的同步的问题。在我们的措施中，Account中的amount会同时被多个线程所会见，这就是一个竞争资源，凡是称作竞态条件。对付这样的多个线程共享的资源我们必需举办同步，以制止一个线程的窜改被另一个线程所包围。在我们这个措施中，Account中的amount是一个竞态条件，所以所有对amount的修改会见都要举办同步，我们将deposit()和withdraw()要领举办同步，修改为：

public synchronized void deposit(float amt)
{
　 float tmp = amount;
　 tmp += amt;
　 try
　 {
　　 Thread.sleep(1);
　　 //模仿其它处理惩罚所需要的时间，好比刷新数据库等
　 }
　 catch (InterruptedException e)
　 {
　　 // ignore
　 }
　 amount = tmp;
}
　　 public synchronized void withdraw(float amt)
{
　 float tmp = amount;
　 tmp -= amt;
　 try
　 {
　　 Thread.sleep(1);
　　 //模仿其它处理惩罚所需要的时间，好比刷新数据库等
　 }
　 catch (InterruptedException e)
　 { // ignore }
　 amount = tmp;
}

#p#分页标题#e#

此时，再运行，我们就可以或许获得正确的功效了。Account中的getBalance()也会见了amount，为什么差池getBalance()同步呢？因为getBalance()并不会修改amount的值，所以，同时多个线程对它会见不会造成数据的杂乱。