多Worker函数

1
function main() {
2
    var m = getCurrentWorkerName();
3
    logd(m);
4
}
5

6
main();

1
function startNewWorker(workName) {
2
    let name = workerThread.newWorker(workName);
3
    logd("startNewWorker " + name)
4
    sleep(1000)
5
    if (!workerThread.isRunning(workName)) {
6
        logd(workName + " 没运行");
7
        return false
8
    }
9
    return true;
10
}
11

12
function testworker() {
13
    logd("current worker name " + getCurrentWorkerName())
14
    // 脚本的主线程
15
    if (getCurrentWorkerName() == "mainWorker") {
16
        logd("主脚本线程")
17
        // 启动worker1
18
        startNewWorker("worker1");
19
        startNewWorker("worker2");
20
        startNewWorker("worker3");
21
        // 已经运行了
22
        for (let i = 0; i < 10; i++) {
23
            if (isScriptExit()) {
24
                logd("mainworker 退出了")
25
                return
26
            }
27
            sleep(1000)
28
            logd(getCurrentWorkerName() + " --> " + new Date())
29
            // 每2秒调用一次worker1的函数
30
            if (i % 2 == 0) {
31
                let dsx = JSON.stringify({"日期": new Date()});
32
                if (workerThread.hasWorkerFunction("getWorker1Data")) {
33
                    let result = workerThread.callWorkerFunction("getWorker1Data", dsx)
34
                    logd("worker1" + "#getWorker1Data 返回--->::::  " + result)
35
                    let removeWorker1 = workerThread.removeWorker("worker1")
36
                    logd("removeWorker1  " + removeWorker1)
37
                    logd("isCancelled worker1 " + workerThread.isCancelled("worker1"));
38
                    // 移出函数getWorker1Data函数
39
                    workerThread.removeWorkerFunction("getWorker1Data")
40
                } else {
41
                    logw("无 getWorker1Data 函数，不调用")
42
                }
43
            }
44
            // 每4秒调用一次worker2的函数
45
            if (i % 4 == 0) {
46
                let dsx = JSON.stringify({"日期": new Date()});
47
                let result = workerThread.callWorkerFunction("getWorker2Data", dsx)
48
                logd("worker2" + "#getWorker2Data 返回--->::::  " + result)
49
            }
50
            // 每6秒调用一次worker6的函数
51
            if (i % 6 == 0) {
52
                let dsx = JSON.stringify({"日期": new Date()});
53
                let result = workerThread.callWorkerFunction("getWorker3Data", dsx)
54
                logd("worker3" + "#getWorker3Data 返回--->::::  " + result)
55
                // 停止所有worker线程
56
                workerThread.stopAll()
57
            }
58
        }
59
    } else {
60
        logd("非主脚本线程 ------ ")
61
        // 如果是worker1的线程，让他干别的活
62
        if (getCurrentWorkerName() == "worker1") {
63
            workerThread.addWorkerFunction("getWorker1Data", function (data) {
64
                logd("---->worker1得到的参数  " + data)
65
                return "我是worker1#getWorker1Data 函数返回的数据 " + new Date()
66
            })
67
            while (true) {
68
                if (isScriptExit()) {
69
                    logd("worker1 退出了")
70
                    return
71
                }
72
                sleep(1000)
73
                //logw(getCurrentWorkerName() + " worker2 " + new Date())
74
            }
75
        }
76
        if (getCurrentWorkerName() == "worker2") {
77
            workerThread.addWorkerFunction("getWorker2Data", function (data) {
78
                logd("---->worker2得到的参数  " + data)
79
                logd("getWorker2Data getCurrentWorkerName " + getCurrentWorkerName())
80
                return "我是worker2#getWorker2Data 函数返回的数据 " + new Date()
81
            })
82
            while (true) {
83
                if (isScriptExit()) {
84
                    logd("worker2 退出了")
85
                    return
86
                }
87
                sleep(1000)
88
                //logw(getCurrentWorkerName() + " worker2 " + new Date())
89
            }
90
        }
91
        if (getCurrentWorkerName() == "worker3") {
92
            workerThread.addWorkerFunction("getWorker3Data", function (data) {
93
                logd("---->worker3得到的参数  " + data)
94
                return "我是worker3#getWorker3Data 函数返回的数据 " + new Date()
95
            })
96
            while (true) {
97
                if (isScriptExit()) {
98
                    logd("worker3 退出了")
99
                    return
100
                }
101
                sleep(1000)
102
                //logw(getCurrentWorkerName() + " worker3 " + new Date())
103
            }
104
        }
105
    }
106
}
107

108
testworker()

1
// 请看 newWorker 例子

1
// 请看 newWorker 例子

1
// 请看 newWorker 例子

1
// 请看 newWorker 例子

1
// 请看 newWorker 例子

1
// 请看 newWorker 例子

1
// 请看 newWorker 例子

1
// 请看 newWorker 例子