在编写一个类时,如果该类中的代码可能运行于多线程环境下,那么就要考虑同步的问题。在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()); }}
版权与免责声明
1、本站所发布的文章仅供技术交流参考,本站不主张将其做为决策的依据,浏览者可自愿选择采信与否,本站不对因采信这些信息所产生的任何问题负责。
2、本站部分文章来源于网络,其版权为原权利人所有。由于来源之故,有的文章未能获得作者姓名,署“未知”或“佚名”。对于这些文章,有知悉作者姓名的请告知本站,以便及时署名。如果作者要求删除,我们将予以删除。除此之外本站不再承担其它责任。
3、本站部分文章来源于本站原创,本站拥有所有权利。
4、如对本站发布的信息有异议,请联系我们,经本站确认后,将在三个工作日内做出修改或删除处理。
请参阅权责声明!