第七色在线视频,2021少妇久久久久久久久久,亚洲欧洲精品成人久久av18,亚洲国产精品特色大片观看完整版,孙宇晨将参加特朗普的晚宴

為了賬號(hào)安全,請(qǐng)及時(shí)綁定郵箱和手機(jī)立即綁定

多線程上鎖+條件(Lock + Condition)

標(biāo)簽:
Java

public class UnsynchBankTest {

public static final int NACCOUNTS = 100;
public static final double INITIAL_BALANCE = 1000;
public static final double MAX_AMOUNT = 1000;
public static final int DELAY = 10;

public static void main(String[] args) {
    Bank bank = new Bank(NACCOUNTS, INITIAL_BALANCE);//创建一个银行对象;这个银行有一百个用户;一百个用户使用这个银行
    for (int i = 0; i < NACCOUNTS; i++) {
        int fromAccount = i;
        Runnable r = () -> {
            try
            {
                while (true) {

                    int toAccount = (int) (bank.size() * Math.random());//拿出一个随机账户
                    double amount = MAX_AMOUNT * Math.random();//设定随机一笔钱(支出/得到)
                    bank.transfer(fromAccount, toAccount, amount);//转账操作
                    Thread.sleep((int) (DELAY * Math.random()));//随机的休眠时间
                }
            }
            catch (InterruptedException e) {
                Thread.currentThread().interrupt();//加上这句为好
            }
        };
        Thread t = new Thread(r);//创建一个线程;该线程处于创建状态
        t.start();//使线程处于可运行的状态(可能运行,也可能处于阻塞状态)
    }
}

}

import java.util.Arrays;
import java.util.concurrent.locks.Condition;
import java.util.concurrent.locks.Lock;
import java.util.concurrent.locks.ReentrantLock;

public class Bank {

private final double[] accounts;
private Lock bankLock;
private Condition sufficientFunds;

public Bank(int n, double initialBalance) {
    accounts = new double[n];//n个账户
    Arrays.fill(accounts, initialBalance);//每个账户初始资金为1000元
    bankLock = new ReentrantLock();//建立锁对象(避免线程共享的bank对象内容发生混乱)
    sufficientFunds = bankLock.newCondition();//建立条件对象(便于得到锁对象的线程在不能做有用的工作时对该线程进行处理)
}

public void transfer(int from, int to, double amount) throws InterruptedException {//所有线程都共享一个bank对象

    bankLock.lock();//上锁;一个线程正在执行这条语句下方语句(得到锁);其它线程就会在这里停顿(没有得到锁)
    try
    {//临界区
        while (accounts[from] < amount)//这个账户余额不满足支出时
            sufficientFunds.await();//条件对象调用该方法使该线程进入条件的等待集(只有被唤醒时才又有可能得到锁,没被唤醒即便锁可用也不能同其它线程竞争)
        System.out.print(Thread.currentThread());//打印当前线程信息
        accounts[from] -= amount;//该账户支出一笔钱
        System.out.printf("%10.2f from %d to %d", amount, from, to);
        accounts[to] += amount;//一个随机账户得到这笔钱
        System.out.printf("Total Balance: %10.2f%n", getTotalBalance());//因为getTotalBalance()方法在被保护(上锁)的代码中;所以这个方法也得上锁才能被调用
        sufficientFunds.signalAll();//唤醒所有等待的线程(使这些线程处于可运行的状态)
    }
    finally
    {
        bankLock.unlock();//保护代码块执行完毕,释放锁
    }

}

public double getTotalBalance() {//该方法在上面的保护代码块中被调用,所以这个方法也得上锁

    bankLock.lock();//上锁
    try
    {
        double sum = 0;

        for (double a : accounts)
            sum += a;

        return sum;
    }
    finally
    {
        bankLock.unlock();//释放锁
    }
}

public int size() {
    return accounts.length;
}

}

點(diǎn)擊查看更多內(nèi)容
TA 點(diǎn)贊

若覺得本文不錯(cuò),就分享一下吧!

評(píng)論

作者其他優(yōu)質(zhì)文章

正在加載中
  • 推薦
  • 1
  • 收藏
  • 共同學(xué)習(xí),寫下你的評(píng)論
感謝您的支持,我會(huì)繼續(xù)努力的~
掃碼打賞,你說多少就多少
贊賞金額會(huì)直接到老師賬戶
支付方式
打開微信掃一掃,即可進(jìn)行掃碼打賞哦
今天注冊(cè)有機(jī)會(huì)得

100積分直接送

付費(fèi)專欄免費(fèi)學(xué)

大額優(yōu)惠券免費(fèi)領(lǐng)

立即參與 放棄機(jī)會(huì)
微信客服

購課補(bǔ)貼
聯(lián)系客服咨詢優(yōu)惠詳情

幫助反饋 APP下載

慕課網(wǎng)APP
您的移動(dòng)學(xué)習(xí)伙伴

公眾號(hào)

掃描二維碼
關(guān)注慕課網(wǎng)微信公眾號(hào)

舉報(bào)

0/150
提交
取消