Comments (3)
The way to accomplish that would be to set up a per-worker MessagePort
between the main thread and the worker. There's currently no way of broadcasting to all workers in the pool (although, that may be something we want to try to figure out later @addaleax) so the communication would need to be 1-1 for each worker. The essential idea is that when the configuration change occurs, you'd post a message to the worker via the MessagePort
. Alternatively, you can pass configuration context as a parameter of a new job for the worker.
from piscina.
My final solution was to initiate a new instance of Piscina, so all further calls of runTask() will go to new instance
from piscina.
My final solution was to initiate a new instance of Piscina, so all further calls of runTask() will go to new instance
much easier and straight forward :)
from piscina.
Related Issues (20)
- The value of "val" is out of range HOT 3
- resourceLimits Working HOT 3
- Make Max Threads default to `os.availableParallelism()` https://nodejs.org/api/os.html#osavailableparallelism HOT 3
- Is there a programmatic way to kill all workers of a queue? HOT 4
- Errors thrown from Node vm.Script cause pool.run() to resolve to null instead of rejecting HOT 3
- Error [ERR_MODULE_NOT_FOUND]: Cannot find module '...\app.asar\out\main\worker.js' imported from ...\app.asar\node_modules\piscina\dist\src\worker.js HOT 3
- Express js
- RangeError in Piscina -> RecordableHistogram HOT 3
- Can worker objects be emitted together during the emit event? HOT 3
- When I try to send a message to the worker thread, an error occurs HOT 3
- docs: New documentation site HOT 7
- Expose `Task` and `TaskQueue` interfaces HOT 1
- Update supported Nodejs version in docs HOT 3
- Class extends value undefined is not a constructor or null HOT 8
- Error: TypeError: (0 , os_1.availableParallelism) is not a function
- Errors.CloseTimeout (Close operation timed out) HOT 2
- ReferenceError [Error]: module is not defined in ES module scope HOT 3
- Fast API HOT 2
- package.json is parsed at static path
- Using Pino Transports <> Piscina results in extra worker_threads for log transports HOT 3
Recommend Projects
-
React
A declarative, efficient, and flexible JavaScript library for building user interfaces.
-
Vue.js
🖖 Vue.js is a progressive, incrementally-adoptable JavaScript framework for building UI on the web.
-
Typescript
TypeScript is a superset of JavaScript that compiles to clean JavaScript output.
-
TensorFlow
An Open Source Machine Learning Framework for Everyone
-
Django
The Web framework for perfectionists with deadlines.
-
Laravel
A PHP framework for web artisans
-
D3
Bring data to life with SVG, Canvas and HTML. 📊📈🎉
-
Recommend Topics
-
javascript
JavaScript (JS) is a lightweight interpreted programming language with first-class functions.
-
web
Some thing interesting about web. New door for the world.
-
server
A server is a program made to process requests and deliver data to clients.
-
Machine learning
Machine learning is a way of modeling and interpreting data that allows a piece of software to respond intelligently.
-
Visualization
Some thing interesting about visualization, use data art
-
Game
Some thing interesting about game, make everyone happy.
Recommend Org
-
Facebook
We are working to build community through open source technology. NB: members must have two-factor auth.
-
Microsoft
Open source projects and samples from Microsoft.
-
Google
Google ❤️ Open Source for everyone.
-
Alibaba
Alibaba Open Source for everyone
-
D3
Data-Driven Documents codes.
-
Tencent
China tencent open source team.
from piscina.