Java规避线程死锁：终止线程循环等待

短命女 2022-11-19 11:23 200阅读 0赞

测试用储户实体类：

package domain;
    
    import java.util.ArrayList;
    
    /**
     * 规避死锁问题的共享存取实体类
     * 
     * @author WanAkiko
     * 
     */
    public class Depositor {
    
    	private String account;
    	private Double balance;
    	private ArrayList<Depositor> list = new ArrayList<Depositor>();
    
    	public Depositor() {
    		super();
    	}
    
    	public Depositor(String account, Double balance) {
    		super();
    		this.account = account;
    		this.balance = balance;
    	}
    
    	/**
    	 * 资金收入
    	 */
    	public void earning(Double money) {
    		this.balance += money;
    	}
    
    	/**
    	 * 资金支出
    	 */
    	public void expenditure(Double money) {
    		this.balance -= money;
    	}
    
    	/**
    	 * 资源上锁
    	 * 
    	 * @param depThis
    	 * @param depThat
    	 * @return
    	 */
    	public synchronized boolean resourceLocked(Depositor depThis,
    			Depositor depThat) {
    		// 若对象序列中存在任意携锁对象则无需继续上锁
    		if (list.contains(depThis) || list.contains(depThat) || list.size() > 0) {
    			return false;
    		}
    		list.add(depThis);
    		list.add(depThat);
    		return true;
    	}
    
    	/**
    	 * 资源释放
    	 * 
    	 * @param depThis
    	 * @param depThat
    	 */
    	public synchronized void resourceRelease(Depositor depThis,
    			Depositor depThat) {
    		list.remove(depThis);
    		list.remove(depThat);
    	}
    
    	public String getAccount() {
    		return account;
    	}
    
    	public void setAccount(String account) {
    		this.account = account;
    	}
    
    	public Double getBalance() {
    		return balance;
    	}
    
    	public void setBalance(Double balance) {
    		this.balance = balance;
    	}
    
    	@Override
    	public String toString() {
    		return "Depositor [account=" + account + ", balance=" + balance + "]";
    	}
    
    }

转账线程：

package domain;
    
    /**
     * 转账线程(终止线程循环等待)
     * 
     * @author WanAkiko
     * 
     */
    public class StopLoopWaitThread implements Runnable {
    
    	private Depositor incomeObject; // 收入对象
    	private Depositor spendingObject; // 支出对象
    	private Depositor thisAcount;
    	private Depositor thatAcount;
    	private Double money = 0.0; // 交易金额
    
    	/**
    	 * 转账线程全参构造
    	 * 
    	 * @param incomeObject
    	 * @param spendingObject
    	 * @param money
    	 */
    	public StopLoopWaitThread(Depositor incomeObject, Depositor spendingObject,
    			Double money) {
    		super();
    		this.incomeObject = incomeObject;
    		this.spendingObject = spendingObject;
    		this.money = money;
    		if (incomeObject.hashCode() > spendingObject.hashCode()) {
    			thisAcount = incomeObject;
    			thatAcount = spendingObject;
    		} else {
    			thisAcount = spendingObject;
    			thatAcount = incomeObject;
    		}
    	}
    
    	@Override
    	public void run() {
    		while (true) {
    			synchronized (thisAcount) {
    				synchronized (thatAcount) {
    					// 为未携带锁的对象扣上资源锁
    					if (incomeObject.getBalance() > money) {
    						// 收入对象的余额大于或等于目标金额时
    						if (incomeObject.getBalance() >= money) {
    							incomeObject.expenditure(money); // 资金支出
    							spendingObject.earning(money); // 资金收入
    							System.out.println("出账用户："
    									+ spendingObject.getAccount() + "，剩余余额："
    									+ spendingObject.getBalance() + "￥；进账用户："
    									+ incomeObject.getAccount() + "，当前余额："
    									+ incomeObject.getBalance() + "￥");
    						}
    					}
    				}
    			}
    		}
    	}
    }

死锁规避测试：

package test;
    
    import domain.Depositor;
    import domain.StopLoopWaitThread;
    
    /**
     * 规避线程死锁(终止线程循环等待)
     * 
     * @author WanAkiko
     *
     */
    public class TerminateWaitTest {
    
    	public static void main(String[] args) {
    		
    		Depositor incomeObject = new Depositor("WanAkiko", 1000.0);
    		Depositor spendingObject = new Depositor("WanQuee", 2000.0);
    		new Thread(new StopLoopWaitThread(incomeObject, spendingObject, 2.0)).start();
    		new Thread(new StopLoopWaitThread(incomeObject, spendingObject, 5.0)).start();
    		
    	}
    	
    }

运行示例：  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzQ0OTY1Mzkz_size_16_color_FFFFFF_t_70]

[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzQ0OTY1Mzkz_size_16_color_FFFFFF_t_70]: /images/20221119/71be03e44b624808b91ebc33a76cf68a.png