Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

make default worker pool an AbstractWorkerPool #49101

Merged
merged 2 commits into from
Apr 6, 2023

Conversation

tanmaykm
Copy link
Member

Changes Distributed._default_worker_pool to hold an AbstractWorkerPool instead of WorkerPool.

With this, alternate implementations can be plugged in as the default pool. Helps in cases where a cluster is always meant to use a certain custom pool. Lower level methods in Distributed (e.g. pmap, remotecalls) can then work without having to pass a custom pool reference with every call.

Changes [Distributed._default_worker_pool](https://github.com/JuliaLang/julia/blob/5f5d2040511b42ba74bd7529a0eac9cf817ad496/stdlib/Distributed/src/workerpool.jl#L242) to hold an `AbstractWorkerPool` instead of `WorkerPool`. With this, alternate implementations can be plugged in as the default pool. Helps in cases where a cluster is always meant to use a certain custom pool. Lower level calls can then work without having to pass a custom pool reference with every call.
@tanmaykm tanmaykm added the domain:parallelism Parallel or distributed computation label Mar 22, 2023
@tanmaykm
Copy link
Member Author

Thanks @JeffBezanson for looking into it!

Should this also be backported to 1.9 and 1.8?

@tanmaykm tanmaykm added backport 1.8 Change should be backported to release-1.8 backport 1.9 Change should be backported to release-1.9 labels Apr 6, 2023
@tanmaykm tanmaykm merged commit def2dda into JuliaLang:master Apr 6, 2023
KristofferC pushed a commit that referenced this pull request Apr 9, 2023
Changes [Distributed._default_worker_pool](https://github.com/JuliaLang/julia/blob/5f5d2040511b42ba74bd7529a0eac9cf817ad496/stdlib/Distributed/src/workerpool.jl#L242) to hold an `AbstractWorkerPool` instead of `WorkerPool`. With this, alternate implementations can be plugged in as the default pool. Helps in cases where a cluster is always meant to use a certain custom pool. Lower level calls can then work without having to pass a custom pool reference with every call.

(cherry picked from commit def2dda)
@KristofferC KristofferC mentioned this pull request Apr 9, 2023
26 tasks
Xnartharax pushed a commit to Xnartharax/julia that referenced this pull request Apr 19, 2023
Changes [Distributed._default_worker_pool](https://github.com/JuliaLang/julia/blob/5f5d2040511b42ba74bd7529a0eac9cf817ad496/stdlib/Distributed/src/workerpool.jl#L242) to hold an `AbstractWorkerPool` instead of `WorkerPool`. With this, alternate implementations can be plugged in as the default pool. Helps in cases where a cluster is always meant to use a certain custom pool. Lower level calls can then work without having to pass a custom pool reference with every call.
@KristofferC KristofferC removed the backport 1.9 Change should be backported to release-1.9 label Apr 25, 2023
Keno pushed a commit that referenced this pull request Jun 5, 2024
Changes [Distributed._default_worker_pool](https://github.com/JuliaLang/julia/blob/5f5d2040511b42ba74bd7529a0eac9cf817ad496/stdlib/Distributed/src/workerpool.jl#L242) to hold an `AbstractWorkerPool` instead of `WorkerPool`. With this, alternate implementations can be plugged in as the default pool. Helps in cases where a cluster is always meant to use a certain custom pool. Lower level calls can then work without having to pass a custom pool reference with every call.
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
Labels
backport 1.8 Change should be backported to release-1.8 domain:parallelism Parallel or distributed computation
Projects
None yet
Development

Successfully merging this pull request may close these issues.

None yet

3 participants