moonpool

simon/moonpool

Fork 0

mirror of https://github.com/c-cube/moonpool.git synced 2025-12-17 08:06:43 -05:00

Commit graph

1d57ae8fbb

remove dead code Simon Cruanes 2023-07-09 17:19:26 -04:00
76ca0f2d88

feat: add Runner, change Pool to produce a Runner.t Simon Cruanes 2023-07-09 17:17:00 -04:00
30d2560a27

add π-computing benchmark Simon Cruanes 2023-07-09 16:58:37 -04:00
2852741360

feat: add a Lock module Simon Cruanes 2023-07-09 16:50:47 -04:00
b07d460b3f

port cpp.ml from containers, replace previous codegen with it Simon Cruanes 2023-07-09 16:13:44 -04:00
0780dcf703

fix warning Simon Cruanes 2023-06-29 10:29:13 -04:00
2acf4b28eb feat: actually support domain-local-await if installed Simon Cruanes 2023-06-19 21:36:58 -04:00
a266a42628 support for domain-local-await when installed Simon Cruanes 2023-06-19 17:27:48 -04:00
79e0aa6f7a

feat: actually support domain-local-await if installed Simon Cruanes 2023-06-19 21:36:58 -04:00
1f29066d59

support for domain-local-await when installed Simon Cruanes 2023-06-19 17:27:48 -04:00
27ec0f85e6 test: add more fork-join tests Simon Cruanes 2023-06-24 15:04:15 -04:00
f46cc4f12c fix: Fork_join.both_ignore now has a more general type Simon Cruanes 2023-06-24 14:58:29 -04:00
b346fa03af rename tests Simon Cruanes 2023-06-24 14:56:20 -04:00
2db2bd9ba2 rename test dir Simon Cruanes 2023-06-24 14:55:39 -04:00
bf43d9648e readme: try to make the random array deterministic Simon Cruanes 2023-06-24 00:31:55 -04:00
4294e90929 readme: add a section on fork-join Simon Cruanes 2023-06-24 00:24:11 -04:00
0f383e877a test: add a parallel quicksort Simon Cruanes 2023-06-24 00:24:02 -04:00
03212e7478 fork-join: add both_ignore Simon Cruanes 2023-06-24 00:23:48 -04:00
43487ebe49 add Fork_join.all_{list,init} Simon Cruanes 2023-06-23 23:18:52 -04:00
45838d9607 fix: in fork-join, start sub-tasks within a handler Simon Cruanes 2023-06-23 21:36:17 -04:00
3b9f56a138 add test for fork_join Simon Cruanes 2023-06-23 18:07:21 -04:00
309424a58f move fork join into its own module Simon Cruanes 2023-06-21 12:28:01 -04:00
009855ce0d feat: add Pool.fork_join Simon Cruanes 2023-06-21 12:22:51 -04:00
2bbb4185a4

readme Simon Cruanes 2023-06-24 15:53:05 -04:00
31d3c92301

test: add more fork-join tests Simon Cruanes 2023-06-24 15:04:15 -04:00
1641118f80

fix: Fork_join.both_ignore now has a more general type Simon Cruanes 2023-06-24 14:58:29 -04:00
08a25832ae

rename tests Simon Cruanes 2023-06-24 14:56:20 -04:00
713ee6c978

rename test dir Simon Cruanes 2023-06-24 14:55:39 -04:00
64542938d2

readme: try to make the random array deterministic Simon Cruanes 2023-06-24 00:31:55 -04:00
34bda683d0

readme: add a section on fork-join Simon Cruanes 2023-06-24 00:24:11 -04:00
177ee06825

test: add a parallel quicksort Simon Cruanes 2023-06-24 00:24:02 -04:00
d6ada57c59

fork-join: add both_ignore Simon Cruanes 2023-06-24 00:23:48 -04:00
f9b85bc0af

add Fork_join.all_{list,init} Simon Cruanes 2023-06-23 23:18:52 -04:00
f3e7646893

fix: in fork-join, start sub-tasks within a handler Simon Cruanes 2023-06-23 21:36:17 -04:00
541916fbd3

add test for fork_join Simon Cruanes 2023-06-23 18:07:21 -04:00
2d0f738070

move fork join into its own module Simon Cruanes 2023-06-21 12:28:01 -04:00
cfe24916bf

feat: add Pool.fork_join Simon Cruanes 2023-06-21 12:22:51 -04:00
456a31c939

dune Simon Cruanes 2023-06-21 12:22:45 -04:00
9f04d254af

feat: Pool.run_wait_block can return a value now Simon Cruanes 2023-06-24 15:00:50 -04:00
e4b159c695

fut: fix warnings Simon Cruanes 2023-06-24 15:03:37 -04:00
ab718b22f9

add Pool.run_wait_block; rename Pool.run into Pool.run_async Simon Cruanes 2023-06-24 14:50:43 -04:00
ffd37642b9

Merge pull request #4 from c-cube/wip-await Simon Cruanes 2023-06-20 22:59:08 -04:00
2b6387e388

mdx for 5.0 only Simon Cruanes 2023-06-19 22:27:39 -04:00
76ec06942a

doc: add more to the readme Simon Cruanes 2023-06-19 22:10:48 -04:00
3676d1e28d

test: remove dep Simon Cruanes 2023-06-19 21:38:54 -04:00
1d23d2d7a1

rename Fut.await_exn to Fut.await Simon Cruanes 2023-06-19 21:23:54 -04:00
68d3487ca8

CI Simon Cruanes 2023-06-19 17:27:58 -04:00
4fd6154b56

refactor suspend Simon Cruanes 2023-06-19 17:06:19 -04:00
f98bcf2f08

add test for await Simon Cruanes 2023-06-19 15:50:40 -04:00
62777e1112

test: add tests for Fut.await Simon Cruanes 2023-06-19 15:34:22 -04:00
e26029ab90

feat: add Fut.await and Fut.await_exn for OCaml >= 5.0 Simon Cruanes 2023-06-19 15:33:28 -04:00
52a04701ed

feat: add Suspend_ module, using effects, on OCaml >= 5.0 Simon Cruanes 2023-06-19 15:32:23 -04:00
eab774813d

test: add load test for chans Simon Cruanes 2023-06-19 20:58:28 -04:00
25e8dcdbce

add ocaml-coc Simon Cruanes 2023-06-20 12:33:23 -04:00
1e21157e8a

feat: add Chan again Simon Cruanes 2023-06-18 21:43:40 -04:00
22ccb76d66

readme Simon Cruanes 2023-06-16 09:18:29 -04:00
67bc47181c

fix: in blocking queue, pop works on a non empty closed queue Simon Cruanes 2023-06-15 22:24:58 -04:00
4e112e1591

add some property tests Simon Cruanes 2023-06-15 21:34:33 -04:00
7707a7c1ce

prepare for 0.2 v0.2 Simon Cruanes 2023-06-15 13:02:43 -04:00
d4a75280de

prepare for 0.1.1 v0.1.1 rel-0.1.1 Simon Cruanes 2023-06-15 13:02:43 -04:00
446d6635a0

fix(fut): fix bug when calling wait_list [] Simon Cruanes 2023-06-15 11:58:55 -04:00
e43c762c96

test: regression test for bug in wait_list on empty list Simon Cruanes 2023-06-15 11:58:32 -04:00
793f57e537

fix: join_array on arrays of length=1 had a bound error Simon Cruanes 2023-06-15 11:42:13 -04:00
5d4a29a056

test: add regression test for bug in join_array Simon Cruanes 2023-06-15 11:42:03 -04:00
b8588f2d65

feat: add Fut.for_list Simon Cruanes 2023-06-15 11:59:10 -04:00
d74c6da3fa

fix(fut): fix bug when calling wait_list [] Simon Cruanes 2023-06-15 11:58:55 -04:00
39712e7f54

test: regression test for bug in wait_list on empty list Simon Cruanes 2023-06-15 11:58:32 -04:00
d60bf3828b

fix: join_array on arrays of length=1 had a bound error Simon Cruanes 2023-06-15 11:42:13 -04:00
c8235f463d

test: add regression test for bug in join_array Simon Cruanes 2023-06-15 11:42:03 -04:00
fc3d2d2645

add around_task to Pool.create Simon Cruanes 2023-06-15 11:19:50 -04:00
b451fde853

add Pool.shutdown_without_waiting Simon Cruanes 2023-06-15 10:52:17 -04:00
059ee8a1d5

add Pool.num_tasks Simon Cruanes 2023-06-15 10:35:41 -04:00
f76b713556

add Fut.is_done Simon Cruanes 2023-06-15 10:24:20 -04:00
f18ed688e9

add Blocking_queue.size Simon Cruanes 2023-06-15 10:20:33 -04:00
debdc8fc31

add Fut.for_array to easily iterate on an array in parallel Simon Cruanes 2023-06-14 11:38:01 -04:00
826d1f15c8

add test Simon Cruanes 2023-06-14 11:34:44 -04:00
dd5a177a5f

add Fut.get_or_fail{,_exn} Simon Cruanes 2023-06-14 11:33:24 -04:00
483392986c

perf: limit number of work queues in pool Simon Cruanes 2023-06-14 11:21:11 -04:00
1d5e962d87

Merge pull request #2 from c-cube/perf-pool-2023-06-12 Simon Cruanes 2023-06-13 22:03:46 -04:00
82af5497f8

pool: do some spinning in run, not in workers Simon Cruanes 2023-06-08 14:49:28 -04:00
939c6e117c

perf: a few retries in the pool Simon Cruanes 2023-06-07 21:12:37 -04:00
bde69ba33f

perf: use multiple queues and non-blocking work stealing from them Simon Cruanes 2023-06-07 21:05:09 -04:00
b084caea69

docs Simon Cruanes 2023-06-13 13:52:06 -04:00
a9a51b08c4

test t_tree_futs: env J to set size of pool Simon Cruanes 2023-06-12 23:15:50 -04:00
9a922088fd

test t_tree_futs: run GC stats thread, for trace Simon Cruanes 2023-06-12 22:55:04 -04:00
df0dae23db

detail in dune Simon Cruanes 2023-06-12 22:54:43 -04:00
948baea4b2

fix test dune file Simon Cruanes 2023-06-12 22:22:04 -04:00
392201445b

test: add t_tree_futs Simon Cruanes 2023-06-12 22:07:36 -04:00
5c462dd688

add trace as test dep Simon Cruanes 2023-06-12 22:07:19 -04:00
d766b362f1

feat fut: add infix, builds a INFIX as a 1st class module Simon Cruanes 2023-06-12 22:06:48 -04:00
7c853861d8

feat fut: add join Simon Cruanes 2023-06-12 22:06:43 -04:00
0177d6aee7

fix fut: actually run all map/bind callbacks if pool is provided Simon Cruanes 2023-06-12 22:06:18 -04:00
c6157ac84d

mdx: depend on moonpool v0.1 Simon Cruanes 2023-06-11 12:37:16 -04:00
5e9470b750

comment Simon Cruanes 2023-06-11 00:06:50 -04:00
bc949727d6

prepare for 0.1 Simon Cruanes 2023-06-10 00:07:51 -04:00
e8ba4feea1

expose Atomic Simon Cruanes 2023-06-10 00:20:24 -04:00
7ee064fc11

more docs on Blocking_queue Simon Cruanes 2023-06-10 00:06:38 -04:00
b4f0c1572e

expose a simple blocking queue, with a controlled API. Simon Cruanes 2023-06-10 00:02:50 -04:00
0a4d87816d

remove chan for now, not ready Simon Cruanes 2023-06-09 23:59:11 -04:00
77ace92ec1

add tests for futures Simon Cruanes 2023-06-09 23:57:27 -04:00