用户注册



邮箱：

密码：

用户登录


邮箱：

密码：
记住登录一个月忘记密码？

发表随想


还能输入：200字
云代码 - java代码库

java 线程的互斥 线程的同步

2012-11-23 作者： 程序猿style举报

[java]代码库

view sourceprint?
/**
 * 线程的互斥，主要展示同步方法与非同步方法的区别
 */
public class Synchronized {
    /**
     * 帐号类
     */
    static class Account{
        //共享资源， 钱数
        private double money = 1000.0d;
        /**
         * 存钱   没有同步机制
         * @param fFees
         */
        public void nonSynDeposit(double fFees){
            System.out.println("Account nonSynDeposit begin! money = " + this.money + "; fFees = " + fFees);
            //存钱钱先等待300毫秒
            System.out.println("Account nonSynDeposit sleep begin!");
            try {
                Thread.sleep(300);
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
            System.out.println("Account nonSynDeposit sleep end!");
            this.money = this.money + fFees;
            System.out.println("Account nonSynDeposit end! money = " + this.money);
        }
        /**
         * 取钱   没有同步机制
         * @param fFees
         */
        public void nonSynWithdraw(double fFees){
            System.out.println("Account nonSynWithdraw begin! money = " + this.money + "; fFees = " + fFees);
            //取钱时先等待400毫秒
            System.out.println("Account nonSynWithdraw sleep begin!");
            try {
                Thread.sleep(400);
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
            System.out.println("Account nonSynWithdraw sleep begin!");
            this.money = this.money - fFees;
            System.out.println("Account nonSynWithdraw end! money = " + this.money);
        }
        /**
         * 存钱   有同步机制
         * @param fFees
         */
        public synchronized void synDeposit(double fFees){
            System.out.println("Account synDeposit begin! money = " + this.money + "; fFees = " + fFees);
            //存钱钱先等待300毫秒
            System.out.println("Account synDeposit sleep begin!");
            try {
                Thread.sleep(300);
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
            System.out.println("Account synDeposit sleep begin!");
            this.money = this.money + fFees;
            System.out.println("Account synDeposit end! money = " + this.money);
        }
        /**
         * 取钱   有同步机制
         * @param fFees
         */
        public synchronized void synWithdraw(double fFees){
            System.out.println("Account synWithdraw begin! money = " + this.money + "; fFees = " + fFees);
            //取钱时先等待400毫秒
            System.out.println("Account synWithdraw sleep begin!");
            try {
                Thread.sleep(400);
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
            System.out.println("Account synWithdraw sleep end!");
            this.money = this.money - fFees;
            System.out.println("Account synWithdraw end! money = " + this.money);
        }
    }
     
    static class AccessThread extends Thread{
        //待访问的帐号对象
        private Account account = null;
        //访问帐号的方法
        private String method = "";
 
        public AccessThread(Account account, String method){
            this.method = method;
            this.account = account;
        }
        public void run(){
            //对不同的方法名参数调用不同的方法
            if (method.equals("nonSynDeposit")){
                account.nonSynDeposit(500.0);
            } else if (method.equals("nonSynWithdraw")){
                account.nonSynWithdraw(200.0);
            } else if (method.equals("synDeposit")){
                account.synDeposit(500.0);
            } else if (method.equals("synWithdraw")){
                account.synWithdraw(200.0);
            }
        }
    }
 
    public static void main(String[] args) {
        //待操作的帐号对象，所有操作都针对该帐号
        Account account = new Account();
         
        System.out.println("使用非同步方法时：");
        //非同步方法存钱的线程
        Thread threadA = new AccessThread(account, "nonSynDeposit");
        //非同步方法取钱的线程
        Thread threadB = new AccessThread(account, "nonSynWithdraw");
        threadA.start();
        threadB.start();
        //等待两线程运行结束
        try {
            threadA.join();
            threadB.join();
        } catch (InterruptedException e) {
            e.printStackTrace();
        }
        //下面测试同步方法
        System.out.println();
        account = new Account();
        System.out.println("使用同步方法时：");
        threadA = new AccessThread(account, "synDeposit");
        threadB = new AccessThread(account, "synWithdraw");
        threadA.start();
        threadB.start();
    }
}


网友评论    (发表评论)


发表评论：

评论须知：

  • 1、评论每次加2分，每天上限为30；
  • 2、请文明用语，共同创建干净的技术交流环境；
  • 3、若被发现提交非法信息，评论将会被删除，并且给予扣分处理，严重者给予封号处理；
  • 4、请勿发布广告信息或其他无关评论，否则将会删除评论并扣分，严重者给予封号处理。


扫码下载

加载中，请稍后...

输入口令后可复制整站源码

加载中，请稍后...