जावास्क्रिप्ट नीति डिजाइन में _thread फ़ंक्शन का अनुप्रयोग

जावास्क्रिप्ट नीति डिजाइन में _thread फ़ंक्शन का अनुप्रयोग

मूल एफएमजेड रणनीति डिजाइन में, असिंक्रोनस समवर्ती संचालन का उपयोग केवल तभी किया जा सकता है जब आवश्यक होexchange.Go()एफएमजेड पैकेजिंग इंटरफेस को लागू करने के लिए फ़ंक्शन के साथ-साथ कई कस्टम ऑपरेशनों (फ़ंक्शन) को निष्पादित करने में असमर्थ है। हालांकि इस डिजाइन ने नीति कार्यक्रमों को निष्पादित करने में काफी सुधार किया है, लेकिन मूल प्रोग्रामिंग भाषाओं में सहपाठियों के लिए जो सह-डिज़ाइन अनुभव के साथ हैं, वे आम तौर पर बहुत असहज महसूस करते हैं।

यहां तक कि एफएमजेड में प्रवेश के लिए क्वांटिफाइड लेनदेन का उपयोग करने वाले नए छात्र भी समझ नहीं पाएंगे।exchange.Go()फ़ंक्शन का उपयोग, उपयोगexchange.Go()ऐसा लगता है कि अभी भी अनुक्रम में निष्पादित कोड में निष्पादन कथन के बाद एक निष्पादन कथन है। तो इस लेख में हम एफएमजेड प्लेटफॉर्म के लिए नए समवर्ती थ्रेड सुविधाओं की खोज करेंगेः__Thread()उदाहरण के लिए, श्रृंखला फ़ंक्शन का उपयोग नीति कार्यक्रम के साथ असंगत रूप से डिज़ाइन किया गया है।

1. सरल समवर्ती डिजाइन

यदि हम चाहते हैं कि नीति मुख्य धागे को चलाने के साथ-साथ एक उप धागे को चलाने के लिए हम अपने द्वारा लिखे गए कस्टम फ़ंक्शन को निष्पादित करें, तो हम निम्न कोड के समान डिज़ाइन का उपयोग कर सकते हैं। नीति कोड में एक फ़ंक्शन को कस्टम करेंGetTickerAsync(), इस फ़ंक्शन के लिए विशिष्ट कार्य लिखें. यह फ़ंक्शन एक मृत चक्र निष्पादित करता है, इस परwhileएफएमजेड के एपीआई इंटरफेस, जो लूप में लगातार कॉल करते हैंःGetTicker()इस तरह से हम बाजार के आंकड़ों को प्राप्त कर सकते हैं।

और फिर इस्तेमाल करें__threadSetData(0, "ticker", t)यह मुख्य स्ट्रिंग में एक डेटा लिखता है, जिसका डेटा नाम हैticker, डेटा मान हैtयानीGetTicker()के लिए लौटाता है।

__threadSetData(0, "ticker", t)

एक बार जब हम कस्टम फ़ंक्शन को डिज़ाइन कर लेते हैं जो स्ट्रिंग के साथ-साथ निष्पादित होते हैं, तो हम लिख सकते हैंmain()और फिर हम एक फ़ंक्शन में कोड है.main()फ़ंक्शन शुरू करने के लिए, हम उपयोग करते हैंः

__Thread(GetTickerAsync, 0)   // GetTickerAsync为需要并发执行的自定义函数，0为这个传入GetTickerAsync函数的参数

एक समवर्ती थ्रेड बनाएँ, और वह शुरू होता है।GetTickerAsync()फ़ंक्शन.main()फ़ंक्शन अपने आप को निष्पादित करना शुरू कर देता हैwhileसर्किट, सर्किट में प्राप्तGetTickerAsync()फ़ंक्शन अपडेट किए गए डेटा को प्रिंट करता हैः

var t = __threadGetData(0, "ticker")
Log(t)

पूर्ण कोड उदाहरणः

function GetTickerAsync(index) {
    while (true) {
        var t = exchanges[index].GetTicker()
        __threadSetData(0, "ticker", t)
        Sleep(500)
    }
}

function main() {
    __Thread(GetTickerAsync, 0)

    while(true) {
        var t = __threadGetData(0, "ticker")
        Log(t)
        Sleep(1000)
    }
}

रीयलटाइम परीक्षणः

यह सबसे सरल अनुप्रयोग डिजाइन है, और अब हम कुछ अन्य आवश्यकताओं के डिजाइन पर ध्यान देंगे।

2। सिंगल डिज़ाइन जारी करें

एक फ़ंक्शन को एक साथ 10 थ्रेड बनाने के लिए डिज़ाइन किया जा सकता है, प्रत्येक थ्रेड एक उप-ऑपरेशन फ़ंक्शन करता है।main()फ़ंक्शन में एक डिजाइन करेंwhileचक्र, पता लगाने की रणनीति इंटरैक्शन निर्देशों को प्राप्त करें।placeMultipleOrdersतो हम एक ही बार में एक ही फ़ंक्शन को कॉल करते हैं.testPlaceMultipleOrders()。

if (cmd == "placeMultipleOrders") {
    // ...
}

नीति संपादन पृष्ठ पर नीति इंटरैक्शन डिज़ाइन जोड़ें, एक बटन सेट करें, आदेशः placeMultipleOrders

पूर्ण कोड उदाहरणः

function placeOrder(exIndex, type, price, amount) {
    var id = null 
    if (type == "Buy") {
        id = exchanges[exIndex].Buy(price, amount)
    } else if (type == "Sell") {
        id = exchanges[exIndex].Sell(price, amount)
    } else {
        throw "type error! type:" + type
    }
}

function testPlaceMultipleOrders(index, beginPrice, endPrice, step, type, amount) {
    Log("beginPrice:", beginPrice, ", endPrice:", endPrice, ", step:", step, ", type:", type, ", amount:", amount)
    var tids = []
    for (var p = beginPrice; p <= endPrice; p += step) {
        var tid = __Thread(placeOrder, index, type, p, amount)
        tids.push(tid)
        Sleep(10)
    }
    Sleep(1000)
    for (var i = 0; i < tids.length; i++) {
        __threadTerminate(tids[i])
    }
}

function main() {
    while(true) {
        LogStatus(_D())
        var cmd = GetCommand()
        if (cmd) {
            if (cmd == "placeMultipleOrders") {
                var t = _C(exchange.GetTicker)
                var beginPrice = t.Last * 0.8
                var endPrice = t.Last * 0.9
                var step = t.Last * 0.01
                testPlaceMultipleOrders(0, beginPrice, endPrice, step, "Buy", 0.01)
                var orders = exchange.GetOrders()
                for (var i = 0; i < orders.length; i++) {
                    Log(orders[i])
                }
            }
        }
        Sleep(1000)
    }
}

• परीक्षण के लिए एक लटकन सूची का उपयोग करें, वर्तमान मूल्य से 80% ~ 90% की वृद्धि, एक एनालॉग डिस्क वातावरण परीक्षण का उपयोग करें, एक इंटरैक्टिव बटन पर क्लिक करके परीक्षण को ट्रिगर करेंः

  

• "PlaceMultipleOrders" बटन पर क्लिक करने के बाद, यह संकेत देता हैः

  

• नीति लॉग में दिखाया गया है कि एक साथ क्या करना हैः

  

3। समवर्ती थ्रेड निष्पादन में वेबसॉकेट कनेक्शन बनाएं

यह आवश्यकता एक FMZ उपयोगकर्ता द्वारा की गई थी, जो चाहता था कि एक सरल उदाहरण दिखाए कि इसे समवर्ती धागे में कैसे उपयोग किया जाए।वेबसॉकेटऔर यह कैसे डेटा को मुख्य धागे पर ले जाने के लिए डिज़ाइन किया गया हैmain()फ़ंक्शन ।

वास्तव में यह बहुत सरल है, और पिछले उदाहरण में समान रूप से समवर्ती धागे बनाने के लिए समान है; केवल धागे के बीच संचार का उपयोग करें।__threadPeekMessage()फ़ंक्शन और__threadPostMessage()फ़ंक्शन. बिटकॉइन एक्सचेंज के वेबसॉकेट एपीआई इंटरफेस कॉल के उदाहरण के रूप में, डिजाइन में हमें वेबसॉकेट कनेक्शन के बंद होने के लिए भी ध्यान देने की आवश्यकता है, नीचे दिए गए उदाहरण में यह भी दिखाया गया है कि एक समवर्ती थ्रेड को सूचित करने के लिए इसे कैसे रोकें।

पूर्ण कोड उदाहरणः

var tid = null 

function createWS() {
    // wss://stream.binance.com:9443/ws/<streamName> , <symbol>@ticker
    
    var stream = "wss://stream.binance.com:9443/ws/btcusdt@ticker"    
    var ws = Dial(stream)
    Log("创建WS连接:", stream)
    
    while (true) {
        var data = ws.read()
        if (data) {            
            __threadPostMessage(0, data)
        }
        Log("接收到WS链接推送的数据，data:", data)
        
        // __threadPeekMessage 超时参数设置-1，不阻塞
        var msg = __threadPeekMessage(-1)
        if (msg) {
            if (msg == "stop") {
                Log("并发线程Id:", __threadId(), "接收到stop指令")
                break
            }
        }
    }

    Log("并发线程执行完毕，关闭ws连接")
    ws.close()
}

function main() {
    tid = __Thread(createWS)
    Log("创建并发线程，线程Id:", tid)

    while(true) {
        // __threadPeekMessage 的超时参数设置为0，阻塞等待数据
        var data = __threadPeekMessage(0)
        Log("接收到并发线程", ", Id:", tid, ", 发送的数据，data:", data, "#FF0000")
        
        var tbl = {
            type : "table", 
            title : "<symbol>@ticker频道推送消息",
            cols : ["事件类型", "事件时间", "交易对", "24小时价格变化", "24小时价格变化百分比", "平均价格", "最新成交价格", "24小时内成交量", "24小时内成交额"],
            rows : []
        }

        try {
            data = JSON.parse(data)
            tbl.rows.push([data.e, _D(data.E), data.s, data.p, data.P, data.w, data.c, data.v, data.q])
        } catch (e) {
            Log("e.name:", e.name, "e.stack:", e.stack, "e.message:", e.message)
        }
        LogStatus(_D(), "\n`" + JSON.stringify(tbl) + "`")
    }
}

function onexit() {
    Log("扫尾函数，向Id为", tid, "的并发线程发送stop指令")
    __threadPostMessage(tid, "stop")
    Log("等待Id为", tid, "的并发线程停止")
    __threadJoin(tid)
    Log("扫尾函数执行完毕")
}

रीयलटाइम परीक्षणः

आप देख सकते हैंmain()यह फ़ंक्शन वेबसॉकेट कनेक्शन से प्राप्त होने वाले ट्रैफ़िक डेटा को लगातार प्राप्त करता है जो समवर्ती धागे द्वारा बनाए गए हैं।

जब नीति को रोक दिया जाता है, तो पूंछ फ़ंक्शन काम करना शुरू कर देता हैः