node工作线程worker_threads的基本使用

目录

• 前言
• 主线程与工作线程
• 工作线程交互
• 尾言

import {Worker} from "worker_threads"

const work = new Worker("./work.js") 

work.postMessage({x: 1, y: 2})

work.on("message", value => {
    console.log(value)
})

import {parentPort} from "worker_threads"

const getSum = (x, y) => {
    return x + y  
}

parentPort.onmessage = (event) => {
    const {x, y} = event.data
    const res = getSum(x, y)
    parentPort.postMessage(res)
}

import {MessageChannel} from "worker_threads"

const {port1, port2} = new MessageChannel()

port1.postMessage("123")

port2.onmessage = ev => {
    console.log(ev.data) 
}

import {Worker, MessageChannel} from "worker_threads"

let work1 = new Worker("./work1.js")
let work2 = new Worker("./work2.js")

const {port1, port2} = new MessageChannel()

work1.postMessage({type: "port"}, [port1])
work2.postMessage({type: "port"}, [port2])

work1.postMessage({type: "send", value: "从线程1向线程2传递信息"})
work2.postMessage({type: "send", value: "从线程2向线程1传递信息"})

import {parentPort} from "worker_threads"

let port1

parentPort.onmessage = (event) => {
    const {type, value} = event.data
    switch (type) {
        case "port":
            port1 = event.ports[0]
            port1.onmessage = ev => {
                console.log(ev.data) 
            }
            break
        case "send":
            port1.postMessage(value)
            break
        default:
            break
    }
}

import {parentPort} from "worker_threads";

let port2

parentPort.onmessage = (event) => {
    const {type, value} = event.data
    switch (type) {
        case "port":
            port2 = event.ports[0]
            port2.onmessage = ev => {
                console.log(ev.data)
            }
            break
        case "send":
            port2.postMessage(value)
            break
        default:
            break
    }
}