Server : Apache/2.4.6 (CentOS) OpenSSL/1.0.2k-fips PHP/7.4.20 System : Linux st2.domain.com 3.10.0-1127.10.1.el7.x86_64 #1 SMP Wed Jun 3 14:28:03 UTC 2020 x86_64 User : apache ( 48) PHP Version : 7.4.20 Disable Function : NONE Directory : /home/real/node-v13.0.1/test/parallel/ |
'use strict';
const common = require('../common');
const assert = require('assert');
const { MessageChannel, MessagePort, Worker } = require('worker_threads');
{
const channel = new MessageChannel();
channel.port1.on('message', common.mustCall(({ typedArray }) => {
assert.deepStrictEqual(typedArray, new Uint8Array([0, 1, 2, 3, 4]));
}));
const typedArray = new Uint8Array([0, 1, 2, 3, 4]);
channel.port2.postMessage({ typedArray }, [ typedArray.buffer ]);
assert.strictEqual(typedArray.buffer.byteLength, 0);
channel.port2.close();
}
{
const channel = new MessageChannel();
channel.port1.on('close', common.mustCall());
channel.port2.on('close', common.mustCall());
channel.port2.close();
}
{
const channel = new MessageChannel();
const w = new Worker(`
const { MessagePort } = require('worker_threads');
const assert = require('assert');
require('worker_threads').parentPort.on('message', ({ port }) => {
assert(port instanceof MessagePort);
port.postMessage('works');
});
`, { eval: true });
w.postMessage({ port: channel.port2 }, [ channel.port2 ]);
assert(channel.port1 instanceof MessagePort);
assert(channel.port2 instanceof MessagePort);
channel.port1.on('message', common.mustCall((message) => {
assert.strictEqual(message, 'works');
w.terminate();
}));
}