Simon Cruanes
2068088255
some comments
2023-08-29 14:26:55 -04:00
Simon Cruanes
0345b65fb4
fix build on < 5.0
2023-08-29 14:22:14 -04:00
Simon Cruanes
c1b6312cad
Update src/d_pool_.ml
2023-08-29 14:22:13 -04:00
David Allsopp
c0db72b40c
Quickly hacked version joining a previous domain
...
Ensure domains have been cleaned up before re-using a slot.
2023-08-29 14:22:13 -04:00
Simon Cruanes
25d42d5b8c
doc
2023-08-29 14:22:13 -04:00
Simon Cruanes
0f670c47d3
perf: in Bb_queue, only signal condition on push if queue was empty
2023-08-23 21:31:42 -04:00
Simon Cruanes
18d5bad2a9
domain pool: let domains live a bit longer
...
this is an optimization to ensure we don't stop/start domains too often,
which harms performance really badly.
2023-08-13 22:48:04 -04:00
Simon Cruanes
ed531e68e1
fix: race condition in shutdown, we need to wait for domain to quit
...
risk is a tight loop of `Pool.with_`, where by not waiting for the pool
to entirely shutdown (including the domains, potentially) we risk
running out of domains in the next iterations.
2023-08-13 22:24:18 -04:00
Simon Cruanes
e38ee31b93
bugfix: forgot to dispose of the worker state on winding down
2023-08-12 22:07:08 -04:00
Simon Cruanes
9db0a9fe28
full lifecycle for worker domains
...
domains can now stop when all worker threads running on them are done
2023-08-12 14:09:35 -04:00
Simon Cruanes
5680938a6c
fix: generalize type of create_arg
2023-08-01 12:34:13 -04:00
Simon Cruanes
aa0dea3e34
add Fut.{reify_error,bind_reify_error}
2023-07-26 16:22:42 -04:00
Simon Cruanes
8e9628ac81
prepare for 0.3
2023-07-16 23:36:34 -04:00
Simon Cruanes
20240a6190
fix: Fork_join.for_ 0 must not hang
2023-07-13 12:23:25 -04:00
Simon Cruanes
d995992917
remove Fork_join.map_reduce_commutative
...
A bit too specialized, and not hard to do with `for_`. Let's see if it shows
to be really useful.
2023-07-10 23:20:24 -04:00
Simon Cruanes
9ce94fd242
feat fork_join: add map_array and map_list
2023-07-10 23:18:26 -04:00
Simon Cruanes
1cb5342092
expose Runner
2023-07-10 22:48:04 -04:00
Simon Cruanes
6c73afbe5b
perf: optimize Fut.for_ a bit
...
remove intermediate array.
2023-07-10 11:00:34 -04:00
Simon Cruanes
0f4e115bc0
doc
2023-07-10 01:31:12 -04:00
Simon Cruanes
f081c0f8ad
tweak: guess of chunk_size in Fork_join
2023-07-10 01:23:30 -04:00
Simon Cruanes
2326ae0078
modify Fork_join.for_ to avoid the allocator.
...
The allocator means calling a closure at each step, which means local
a reference will have to be heap allocated (and worse, that floats will
be unboxed). Instead we give the function a pair of low,high bounds for
a local for.
2023-07-10 01:19:16 -04:00
Simon Cruanes
55f831bc8b
add Fork_join.{for_,map_reduce_commutative}
2023-07-10 01:14:16 -04:00
Simon Cruanes
858755e812
feat: add Pool.with_
2023-07-10 01:14:07 -04:00
Simon Cruanes
427c462778
compat 4.x
2023-07-09 22:05:42 -04:00
Simon Cruanes
68e744290b
add Chan.pop_await
2023-07-09 19:49:27 -04:00
Simon Cruanes
12df71c3ab
expose Suspend_ and its internal effect with an unstability alert
2023-07-09 19:49:27 -04:00
Simon Cruanes
e855c99bec
update doc for Fut
2023-07-09 19:49:27 -04:00
Simon Cruanes
39525af7ac
add documentation; expose Runner.For_runner_implementors.Suspend_
2023-07-09 19:49:26 -04:00
Simon Cruanes
1d57ae8fbb
remove dead code
2023-07-09 19:49:26 -04:00
Simon Cruanes
76ca0f2d88
feat: add Runner, change Pool to produce a Runner.t
...
futures, chans, etc. should use the `Runner.t` abstraction
and not depend on the exact pool implementation to run tasks.
For now `Pool.create` is the only implementation of a runner, but now
it's possible to implement alternatives.
2023-07-09 19:49:25 -04:00
Simon Cruanes
2852741360
feat: add a Lock module
2023-07-09 19:49:25 -04:00
Simon Cruanes
b07d460b3f
port cpp.ml from containers, replace previous codegen with it
...
now OCaml 5-only features are truly available only on OCaml 5, instead
of just relying on the user reading the docstring.
2023-07-09 19:49:24 -04:00
Simon Cruanes
0780dcf703
fix warning
2023-07-06 09:46:33 -04:00
Simon Cruanes
2acf4b28eb
feat: actually support domain-local-await if installed
2023-07-05 22:19:18 -04:00
Simon Cruanes
a266a42628
support for domain-local-await when installed
2023-07-05 22:19:18 -04:00
Simon Cruanes
f46cc4f12c
fix: Fork_join.both_ignore now has a more general type
2023-07-05 21:55:00 -04:00
Simon Cruanes
03212e7478
fork-join: add both_ignore
2023-07-05 21:55:00 -04:00
Simon Cruanes
43487ebe49
add Fork_join.all_{list,init}
...
primitives to fork-join over n tasks
2023-07-05 21:55:00 -04:00
Simon Cruanes
45838d9607
fix: in fork-join, start sub-tasks within a handler
2023-07-05 21:55:00 -04:00
Simon Cruanes
309424a58f
move fork join into its own module
2023-07-05 21:55:00 -04:00
Simon Cruanes
009855ce0d
feat: add Pool.fork_join
2023-07-05 21:55:00 -04:00
Simon Cruanes
9f04d254af
feat: Pool.run_wait_block can return a value now
2023-06-24 15:06:40 -04:00
Simon Cruanes
e4b159c695
fut: fix warnings
2023-06-24 15:05:56 -04:00
Simon Cruanes
ab718b22f9
add Pool.run_wait_block; rename Pool.run into Pool.run_async
2023-06-24 14:50:43 -04:00
Simon Cruanes
1d23d2d7a1
rename Fut.await_exn to Fut.await
2023-06-20 22:43:33 -04:00
Simon Cruanes
4fd6154b56
refactor suspend
...
do not wrap each step in a new handler; using Effects.Deep we only wrap
the entrypoint of the task, and subsequent `continue` get scheduled
as-is.
2023-06-20 22:43:15 -04:00
Simon Cruanes
e26029ab90
feat: add Fut.await and Fut.await_exn for OCaml >= 5.0
...
this uses suspension (based on `Suspend_`) to wait for completion of the
future.
2023-06-20 22:43:13 -04:00
Simon Cruanes
52a04701ed
feat: add Suspend_ module, using effects, on OCaml >= 5.0
2023-06-20 22:43:13 -04:00
Simon Cruanes
1e21157e8a
feat: add Chan again
2023-06-18 22:09:22 -04:00
Simon Cruanes
67bc47181c
fix: in blocking queue, pop works on a non empty closed queue
2023-06-15 22:24:58 -04:00
