1

zyy

13 hours ago 4fefff17528a878d345ff3311c297a66a671b8d6

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
package com.yami.trading.huobi.task;
 
import org.springframework.stereotype.Component;
 
import java.util.concurrent.ConcurrentHashMap;
 
@Component
public class KlineContext {
    private ConcurrentHashMap<String, Boolean> klineInitState = new ConcurrentHashMap<>();
    private ConcurrentHashMap<String, Boolean> manalInit = new ConcurrentHashMap<>();
 
    /***
     * 将symbol k线图初始化设置为成功
     * @param symbol
     */
    public void initKlineSuccess(String symbol){
        klineInitState.put(symbol, true);
    }
    /**
     * 判断当前k线图是否已经初始化成功
     * @param symbol
     * @return
     */
    public boolean isInitSuccess(String symbol){
        return klineInitState.getOrDefault(symbol, false);
    }
 
    public void setManualInit(String symbol){
        manalInit.put(symbol, true);
    }
    public void setManualFinish(String symbol){
        manalInit.put(symbol, false);
    }
    public boolean isManualIniting(String symbol){
        return manalInit.getOrDefault(symbol, false);
    }
}