多執行緒共享操作實列

專案需求

最近在做一個和支付相關的專案，由於上游通道對每個商戶交易額度有上限風控。因此我們需要實現一個商戶輪詢的機制，通過使用多個商戶號，來提高交易上限，滿足交易需求。

需求分析

通過需求分析，我們知道商戶的交易額度是共享資源，因此涉及到了共享資源同步的問題，需要我們控制商戶的交易額度，及時切換上送的交易商戶號，保證在多執行緒的情況下執行。

功能實現

不說那麼多了，直接貼程式碼。

根據業務需求，設計介面：

publicinterface IncOrDecInterface {
/**
* 恢復額度
* 當交易失敗時，恢復商戶可使用的交易額度。
* @param amount
*/
boolean inc(Long amount);
/**
* 減少額度
* 交易時，根據交易金額減少商戶可使用額度。
* @param amount
*/
boolean dec(Long amount);
/**
* 更新商戶可使用額度
* 由於商戶額度每天更新一次，因此設計此介面，用於重置或更新商戶可使用額度。
* @param amount
*/
boolean update(Long amount);
/**
* 判斷物件是否有鎖
*/
boolean isLook();
}

商戶物件

publicclass Merchant implements IncOrDecInterface{
privatestaticfinal Logger log = LoggerFactory.getLogger(UnsPayMerchant.class);
private String merchantNo;
private String signKey;
privatevolatilelong maxTransactionAmount;
private Lock lock = new

ReentrantLock();
privateboolean isLook = false;
public String getMerchantNo() {
return merchantNo;
}
publicvoid setMerchantNo(String merchantNo) {
this.merchantNo = merchantNo;
}
public String getSignKey() {
return signKey;
}
publicvoid setSignKey(String signKey) {
this.signKey = signKey;
}
publiclong getMaxTransactionAmount() {
try {
lock.lock();
return maxTransactionAmount;
}finally {
lock.unlock();
}
}
publicvoid setMaxTransactionAmount(long maxTransactionAmount) {
this.maxTransactionAmount = maxTransactionAmount;
}
@Override
publicboolean inc(Long amount) {
try{
lock.lock();
isLook = true;
log.info("商戶號[{}] 當前額度[{}] 充值金額[{}]",this.merchantNo,this.maxTransactionAmount,amount);
this.maxTransactionAmount =this.maxTransactionAmount + amount;
Thread.sleep(1000);
returntrue;
} catch (InterruptedException e) {
e.printStackTrace();
} finally {
lock.unlock();
isLook = false;
}
returnfalse;
}
@Override
publicboolean dec(Long amount) {
try{
lock.lock();
isLook = true;
log.info("當前執行緒[{}] 商戶號[{}] 當前額度[{}] 消費金額[{}]",Thread.currentThread().getName(),this.merchantNo ,this.maxTransactionAmount, amount);
if(this.maxTransactionAmount >= amount){
this.maxTransactionAmount = this.maxTransactionAmount - amount;
returntrue;
}
} finally {
lock.unlock();
isLook = false;
}
returnfalse;
}
@Override
publicboolean update(Long amount) {
try{
lock.lock();
isLook = true;
log.info("商戶號[{}] 當前額度[{}] 恢復額度[{}]", this.merchantNo, this.maxTransactionAmount, amount);
this.maxTransactionAmount = amount;
returntrue;
}finally {
lock.unlock();
isLook = false;
}
}
@Override
publicboolean isLook() {
return isLook;
}
}

商戶容器

publicclass MerchantContainer {
privatestaticfinal Logger log = LoggerFactory.getLogger(MerchantContainer.class);
相關推薦

多執行緒共享操作實列

專案需求最近在做一個和支付相關的專案，由於上游通道對每個商戶交易額度有上限風控。因此我們需要實現一個商戶輪詢的機制，通過使用多個商戶號，來提高交易上限，滿足交易需求。需求分析通過需求分析，我們知道商戶的交易額度是共享資源，因此涉及到了共享資源同步的問題

java多執行緒2：區域性變數的執行緒安全，實列變數的非執行緒安全

java多執行緒2：區域性變數的執行緒安全，實列變數的非執行緒安全 “非執行緒安全“就是在多個執行緒訪問同一個物件的例項變數進行併發訪問時候發生，產生的後果就是”髒讀“，也就是取到的資料其實是被修改過的。 a.多執行緒訪問區域性變數是執行緒安全的。 package multiThread

面試題多執行緒順序操作

問題編寫一個程式，程式會啟動4個執行緒，向4個檔案A，B，C，D裡寫入資料，每個執行緒只能寫一個值。執行緒A：只寫1 執行緒B：只寫2 執行緒C：只寫3 執行緒D：只寫4 4個檔案A，B，C，D。程式執行起來，4個檔案的寫入結果如下：

多執行緒常用操作方法（sleep、yield、join）

執行緒的命名與取得執行緒的命名：通過構造方法在建立執行緒時設定執行緒名稱直接繼承Thread類： public Thread (String name); Runable或者Callable介面實現多執行緒： public Thread (Run

Android開發之多執行緒的操作方式Thread,TimerTask,AsyncTask

雨鬆MOMO原創文章如轉載，請註明：轉載至我的獨立域名部落格雨鬆MOMO程式研究院，原文地址:http://www.xuanyusong.com/archives/344 Android研究院之遊戲開發多執行緒（十六）遊戲開發與軟體開發多執行緒的重要性 &

python-多執行緒-共享變數問題

import threading sum = 0 loopSum = 1000000 lock = threading.Lock() def Add(): global sum, loopSum for i in range(1,loopSum): loc

OpenMP: 多執行緒檔案操作

OpenMP：多執行緒檔案操作簡介具體實現 1. OpenMP常用函式 2. 並行區域 3. for 迴圈並行化基本用法 3.1 資料不相關性 3.2 for迴圈並行化的幾

多執行緒非同步操作日誌

上次寫的一篇部落格,多執行緒非同步操作日誌不完整,現在寫一個完整的功能是:使用者訪問一個controller,將訪問的記錄儲存到佇列中去,在開啟定時器,消費掉記錄儲存到檔案中(可改為儲存到資料庫) 我的idea目錄: controller中的程式碼: package com.

多執行緒共享資源

多執行緒共享資源按照作業系統原理，程序是系統資源分配的最小單位，執行緒是cpu排程的最小單位。執行緒共享程序申請的資源，但是執行緒有維持自己正常執行的很小的資源，這很小的資源為各個執行緒獨有。同一個程序中建立的多執行緒共享的環境包括：程序程式碼段程序的公有資

多執行緒-共享全域性變數

from threading import Thread import time g_num = 100 def work1(): global g_num for i in range(3): g_num += 1 print("----in wo

C語言多執行緒目錄操作

#include <stdio.h>#include <pthread.h>#include <stdlib.h>#include <sys/types.h>#include <dirent.h> #define NUM 2 void threa

為什麼EventLoop能避免多執行緒併發操作和鎖競爭

Netty的Reactor執行緒池就是EventLoopGroup，是一個EventLoop的陣列。EventLoop是用來處理所有註冊到自身這個執行緒的Selector上的channel，Selector的輪詢操作由EventLoop的run方法驅動，在一個迴圈體內迴圈執行，包括使用者自定

Java多執行緒11：多執行緒同步操作

什麼情況下需要同步 1、當多執行緒併發，有多段程式碼同時執行時，有時希望某一段程式碼執行的過程中CPU不要切換到其他執行緒工作。這時就需要執行緒同步。 2、如果兩段程式碼是同步的，那麼同一段時間只能執行

水滴石穿--多執行緒原子操作、threadlocal、volatile、多執行緒下的單例模式

接著上一篇文章，下面看看幾個比較好理解的知識點！！ volatile java關鍵字volatile修飾的變數從字面意義上理解易變的，不穩定的，事實上時告訴編譯器該變數是易變的不要對該變數使用快取等級的優化，每次都從記憶體地址中讀取值。不過並沒有說明在對volatile修飾的變數進行修

python多執行緒-共享全域性變數

目錄多執行緒-共享全域性變數多執行緒-共享全域性變數列表當作實參傳遞到執行緒中總結多執行緒-共享全域性變數問題多執行緒開發可能遇到的問題測試1 測試2 多執行緒-共享全域性變數多執行緒-共享全域性變

JAVA多執行緒——共享變數

【轉載】Java多執行緒程式設計：變數共享分析（Thread）原部落格網址：https://www.cnblogs.com/xudong-bupt/archive/2013/05/22/3087864.html

多執行緒基礎操作

本片部落格會貼上部分程式碼，想要了解更多程式碼資訊，可訪問小編的GitHub關於本篇的程式碼 - 對比程序與執行緒的區別執行緒概念及特點 Linux下執行緒是以程序模擬的，Linux下的程序控制塊pcb實際就是一個執行緒，其他系統不一定 Linux

兩種方式實現多執行緒共享資源（典型的售票例子）

1、繼承Thread TestThread類 public class TestThread extends Thread{ private int ticket = 300; @Override public void run() { while(true){

多程序和多執行緒程式設計操作

1.什麼是程序程序是系統最小的資源管理單元，是一個程式在一個數據集上的一次動態執行過程。 2.什麼是執行緒執行緒是計算機程式執行的實際執行者，是cpu的執行單元，在計算機中，程序主要是為了執行緒的執行進行分配資源操作，程式真正的執行者是執行緒，每一個程序至少有一個執

Hbase批量匯入資料，支援多執行緒同時操作

/** * HBase操作工具類：快取模式多執行緒批量提交作業到hbase * * @Auther: ning.zhang * @Email: [email protected] * @CreateDate: 2018/7/30 */ public c

多執行緒共享操作實列

專案需求

需求分析

功能實現

相關推薦