Pass filename and options from Thread to Worker

Refs: #416

Author: tshemsedinov

lib/locks.js

@@ -81,8 +81,8 @@ if (!isMainThread) {
 }
 
 class Thread {
-  constructor() {
-    const worker = new Worker(__filename);
+  constructor(filename, options) {
+    const worker = new Worker(filename, options);
     this.worker = worker;
     threads.add(this);
     worker.on('message', message => {

test/locks.js

@@ -1,28 +1,33 @@
 'use strict';
 
-const { isMainThread } = require('worker_threads');
-const { locks } = require('..');
-const { Thread } = locks;
-const metatests = require('metatests');
+const common = require('@metarhia/common');
+const nodeVerion = common.between(process.version, 'v', '.');
 
-const sleep = msec =>
-  new Promise(resolve => {
-    setTimeout(resolve, msec);
-  });
+if (nodeVerion >= 11) {
+  const { isMainThread } = require('worker_threads');
+  const { locks } = require('..');
+  const { Thread } = locks;
+  const metatests = require('metatests');
 
-if (isMainThread) {
-  metatests.test('locks: enter and leave', test => {
-    new Thread();
-    new Thread();
+  const sleep = msec =>
+    new Promise(resolve => {
+      setTimeout(resolve, msec);
+    });
 
-    setTimeout(() => {
-      locks.request('A', async lock => {
-        test.end();
-      });
-    }, 100);
-  });
-} else {
-  locks.request('A', async lock => {
-    await sleep(100);
-  });
+  if (isMainThread) {
+    metatests.test('locks: enter and leave', test => {
+      new Thread(__filename);
+      new Thread(__filename);
+
+      setTimeout(() => {
+        locks.request('A', async lock => {
+          test.end();
+        });
+      }, 100);
+    });
+  } else {
+    locks.request('A', async lock => {
+      await sleep(100);
+    });
+  }
 }