package com.xcong.excoin.trade;
|
|
import org.springframework.stereotype.Service;
|
|
import java.util.concurrent.ConcurrentHashMap;
|
|
@Service
|
public class CoinTraderFactory {
|
|
private ConcurrentHashMap<String, CoinTrader> traderMap;
|
|
public CoinTraderFactory() {
|
traderMap = new ConcurrentHashMap<>();
|
}
|
|
//添加,已存在的无法添加
|
public void addTrader(String symbol, CoinTrader trader) {
|
if(!traderMap.containsKey(symbol)) {
|
traderMap.put(symbol, trader);
|
}
|
}
|
|
//重置,即使已经存在也会覆盖
|
public void resetTrader(String symbol, CoinTrader trader) {
|
traderMap.put(symbol, trader);
|
}
|
|
public boolean containsTrader(String symbol) {
|
return traderMap.containsKey(symbol);
|
}
|
|
public CoinTrader getTrader(String symbol) {
|
return traderMap.get(symbol);
|
}
|
|
public ConcurrentHashMap<String, CoinTrader> getTraderMap() {
|
return traderMap;
|
}
|
|
}
|