정책 프로그램을 실제로 동시에 실행할 수 있게 하고 JavaScript 정책에 시스템 수준 멀티스레딩 지원을 추가합니다.

JavaScript 언어를 사용하여 FMZ에서 전략을 개발할 때, 전략 아키텍처는 폴링입니다. 동시 설계 시나리오가 있는 경우exchange.Go함수는 일부 인터페이스에 대한 동시 호출을 만드는 데 사용되며, 이를 통해 일부 동시 시나리오의 요구를 충족시킬 수 있습니다. 그러나 일련의 작업을 수행하기 위해 별도의 스레드를 만들고 싶은 경우 불가능합니다. 예를 들어 Python에서와 같이 다음을 사용합니다.threading라이브러리는 일부 동시적 설계를 하는 데 사용됩니다.

이러한 요구에 따라 FMZ 플랫폼은 기본 시스템을 업그레이드했습니다. JavaScript 언어에 진정한 멀티스레딩 지원도 추가되었습니다. 자세한 기능은 다음과 같습니다.

• 사용자 정의 함수를 동시에 실행하기 위해 스레드를 생성합니다.
• 스레드 간 통신.
• 스레드 간에 저장된 변수를 공유합니다.
• 스레드가 실행을 완료하고 리소스를 회수하여 실행 결과를 반환할 때까지 기다립니다.
• 스레드를 강제로 종료하고 리소스를 회수합니다.
• 동시 스레드 실행 함수에서 현재 스레드 ID를 가져옵니다.

다음으로, 편집기는 각 기능을 하나씩 이해하도록 안내할 것입니다.

사용자 정의 함수를 동시에 실행하기 위한 스레드 생성

__Thread함수는 함수를 동시에 실행하기 위해 스레드를 생성할 수 있습니다. 예를 들어, 동시 함수를 만들어야 합니다.func1，func1이 기능은 어떤 역할을 하나요? 0에서 9까지 누적되도록 할 수 있습니다. 이 점진적인 누적 프로세스를 보려면 func1 함수에서 for 루프를 사용하여 특정 기간 동안 매번 일시 중지합니다(Sleep 함수는 특정 밀리초 수 동안 휴면 상태로 유지하는 데 사용됩니다). 시간의.

function func1(sleepMilliseconds) {
    var sum = 0 
    for (var i = 0 ; i < 10 ; i++) {
        sum += i 
        Sleep(sleepMilliseconds)
        Log("sum:", sum)
    }
    
    return sum
}

function main() {
    // 使用__Thread函数并发创建一个线程，参数200即为func1函数的参数，
    // 如果func1函数有多个参数，这里就具体传对应的参数
    var thread1Id = __Thread(func1, 200)
    
    // 这里需要等待线程Id为thread1Id的线程执行结果，否则main函数执行完就直接释放所有线程
    var ret = __threadJoin(thread1Id)
    Log("ret:", ret)
}

실제 응용 프로그램 시나리오에서는 다음과 같이 동시 http 요청을 할 수 있습니다.

function main() {
    let threads = [
        "https://www.baidu.com",
        "https://www.163.com"
    ].map(function(url) {
        return __Thread(function(url) {
            Log("GET", url)
            return HttpQuery(url)
        }, url)
    })
    threads.forEach(function(tid) {
        Log(__threadJoin(tid))
    })
}

스레드가 실행을 완료하고 리소스를 회수하고 실행 결과를 반환할 때까지 기다립니다.

위의 예에서 우리는 마침내 메인 함수에서 그것을 사용했습니다.__threadJoin동시 스레드가 실행을 완료할 때까지 기다리는 함수, 변수ret인수하다__threadJoin함수의 반환 값입니다. 이 반환 값을 인쇄하고 이 동시 스레드의 실행의 구체적인 결과를 관찰합니다.

// id：线程ID，terminated：是否被强制停止，elapsed：耗时（纳秒），ret：线程执行函数的返回值
ret: {"id":1,"terminated":false,"elapsed":2004884301,"ret":45}

스레드를 강제로 종료하고 리소스를 재활용합니다.

function func1(sleepMilliseconds) {
    var sum = 0 
    for (var i = 0 ; i < 10 ; i++) {
        sum += i 
        Sleep(sleepMilliseconds)
        Log("sum:", sum)
    }
    
    return sum
}

function main() {
    var thread1Id = __Thread(func1, 200)
    Sleep(1000)
    retThreadTerminate = __threadTerminate(thread1Id)
    Log(retThreadTerminate)   // true
}

이전 예를 다시 살펴보면, 스레드를 생성한 후 1초 동안 기다린 후 스레드 실행을 강제로 종료할 수 있습니다.

스레드 간 통신

Interthread 통신은 주로 사용됩니다__threadPostMessage기능 및__threadPeekMessage기능. 다음의 간단한 예를 살펴보겠습니다.

function func1() {
    var id = __threadId()
    while (true) {
        var postMsg = "来自id:" + id + "的线程函数func1的消息"
        __threadPostMessage(0, postMsg)              // 发送消息到主线程
        var peekMsg = __threadPeekMessage()         // 接收来自其它线程的消息
        Log(peekMsg)
        Sleep(5000)
    }
}

function main() {
    var threadId = __Thread(func1)
    
    while (true) {
        var postMsg = "来自主线程的main函数的消息"
        __threadPostMessage(threadId, postMsg)
        var peekMsg = __threadPeekMessage()
        Log(peekMsg, "#FF0000")                     // #FF0000 ， 设置日志为红色用于区分
        Sleep(5000)
    }
}

__threadPostMessage이 함수는 스레드에 메시지를 보내는 데 사용됩니다. 첫 번째 매개변수는 메시지가 전송되는 특정 스레드의 ID이고 두 번째 매개변수는 전송할 메시지로, 문자열, 숫자, 배열, JSON 객체 등 동시 스레드 함수에서 메인 스레드에 메시지를 보낼 수 있습니다. 메인 스레드의 ID는 0으로 정의됩니다.

__threadPeekMessage이 함수는 스레드에서 보낸 메시지를 모니터링하는 데 사용됩니다. 시간 초과(밀리초)를 설정하거나 0으로 설정하여 스레드를 차단하고 메시지가 있을 때까지 모니터링한 후 반환할 수 있습니다.

물론, 메인 스레드와 통신하는 동시 스레드는 제외합니다. 동시 스레드는 서로 직접 통신할 수도 있습니다.

동시 스레드 실행 함수에서 현재 스레드 ID를 가져옵니다.

위의 예에서 다음을 사용하여var id = __threadId()，__threadId()이 함수는 현재 스레드의 ID를 얻을 수 있습니다.

스레드 간에 저장된 변수 공유

스레드 간 통신 외에도 상호 작용을 위해 공유 변수를 사용할 수도 있습니다.

function testFunc() {
    __threadSetData(0, "testFunc", 100)   // 储存在当前线程环境，键值对 testFunc : 100 
    Log("testFunc执行完毕")
}

function main() {
    // threadId为1 ，创建的threadId为1的线程会先执行完，只要线程资源没有被回收，线程本地储存的变量就有效
    var testThread = __Thread(testFunc)
    
    Sleep(1000)

    // 输出 in main, get testFunc: 100
    Log("in main, get testFunc:", __threadGetData(testThread, "testFunc"))   // 取出键名为testFunc的值
}

위의 내용은 모든 기능에 대한 간단한 설명입니다.