Java线程同步实例分析

本文实例讲述了Java线程同步的用法。分享给大家供大家参考。具体分析如下：

多线程的使用为我们的程序提供了众多的方便，同时它也给我们带来了以往没有考虑过的麻烦。当我们使用多线程处理共享资源时意外将会发生：比如我们一起外出就餐，每个人都是一个线程，餐桌上的食物则是共享资源，当我看到红烧鸡腿上桌后立即拿起筷子直奔目标，眼看着就得手的时候，突然～～～鸡腿消失了，一个距离盘子更近的线程正在得意地啃着。

为了避免上述问题的发生，Java为我们提供了“synchronized（同步化）修饰符”来避免资源冲突，你可以将资源类中某个函数或变量声明为synchronized（同步化），每个继承自Object的类都含有一个机锁（Lock），它是余生俱来的，不需要编写任何代码来启用它。当我们调用任何synchronized（同步化）函数时，该对象将被锁定，对象中所有 synchronized（同步化）函数便无法被调用，直到第一个函数执行完毕并解除机锁。

import java.awt.BorderLayout;
import java.awt.event.ActionEvent;
import java.awt.event.ActionListener;
import javax.swing.JButton;
import javax.swing.Jframe;
import javax.swing.JPanel;
import javax.swing.JScrollPane;
import javax.swing.Jtextarea;
import javax.swing.JTextField;

public class TestMain5 extends Jframe {
 private MyAccounts myAccounts = null; // 我的帐号
 private JTextField text = null; // 银行存款数额显示
 private Jtextarea textarea = null; // 交易过程显示
 private JButton button = null; // 开始模拟交易的按钮
 
 public TestMain5(){
  super("线程同步测试");
  myAccounts = new MyAccounts();
  text = new JTextField(Integer.toString(myAccounts.inquire()), 10); // 我们在银行中的初始存款为100
  textarea = new Jtextarea();
  textarea.setText("交易日志：");
  JScrollPane sp = new JScrollPane(textarea);
  button = new JButton("开始交易");
  button.addActionListener(new ActionListener(){
   public void actionPerformed(ActionEvent e) {
    new Bank("钟楼支行", myAccounts, Bank.DEAL_SAVING, 800);
    new Bank("高新支行", myAccounts, Bank.DEAL_SAVING, 1300);
    new Bank("小寨支行", myAccounts, Bank.DEAL_FETCH, 200);
    new Bank("雁塔支行", myAccounts, Bank.DEAL_FETCH, 400);
    new Bank("兴庆支行", myAccounts, Bank.DEAL_SAVING, 100);
    new Bank("土门支行", myAccounts, Bank.DEAL_FETCH, 700);
   }
  });
  JPanel pane = new JPanel();
  pane.add(text);
  pane.add(button);
  this.getContentPane().add(pane, BorderLayout.NORTH);
  this.getContentPane().add(sp);
  this.setDefaultCloseOperation(Jframe.EXIT_ON_CLOSE);
  this.setSize(300, 200);
  this.setLocationRelativeTo(null);
  this.setVisible(true);
 }
 
 class Bank extends Thread{
  
  public static final int DEAL_SAVING = 0;
  
  public static final int DEAL_FETCH = 1;
  private int buy = Bank.DEAL_FETCH; // 默认使取款
  private int count = 0;
  private MyAccounts myAccounts = null; // 我的帐号
  
  public Bank(String name, MyAccounts myAccounts, int buy, int count){
   super(name);
   this.myAccounts = myAccounts;
   this.buy = buy;
   this.count = count;
   this.start();
  }
  public void run(){
   int $count = 0;
   if(buy == Bank.DEAL_SAVING){ // 如果是存款业务
    $count = myAccounts.saving(count);
   }else if(buy == Bank.DEAL_FETCH){ // 如果是取款业务
    $count = myAccounts.fetch(count);
   }
   text.setText(Integer.toString($count));
   textarea.append("n" + this.getName() + " " + (buy == Bank.DEAL_SAVING ? "存款": "取款") + " 金额：" + count + " 结余：" + $count);
  }
 }
 
 class MyAccounts{
  private Integer count = 1100;
  public MyAccounts(){
  }
  
  public int inquire(){
   synchronized (count){
    return count;
   }
  }
  
  public int saving(int c){
   synchronized (count){
    //return count += c; // 为了能更好的观察，我们将这个简洁的语句注释掉
    int $count = inquire(); // 先查询帐户中的存款
    $count += c;
    try {
     Thread.sleep(1000); // 为了更好的观察，使业务在此停顿1秒钟
    } catch (InterruptedException ex) {
     ex.printStackTrace();
    }
    count = $count; // 最后将总数储存起来
    return inquire(); // 返回最新的存款数
   }
  }
  
  public int fetch(int c){
   synchronized (count){
    //return count -= c; // 为了能更好的观察，我们将这个简洁的语句注释掉
    int $count = inquire(); // 先查询帐户中的存款
    $count -= c;
    try {
     Thread.sleep(1000); // 为了更好的观察，使业务在此停顿1秒钟
    } catch (InterruptedException ex) {
     ex.printStackTrace();
    }
    count = $count; // 最后将总数储存起来
    return inquire(); // 返回最新的存款数
   }
  }
 }
 public static void main(String [] args){
  new TestMain5();
 }
}

希望本文所述对大家的java程序设计有所帮助。