github/semantic
1
1
Fork 0
mirror of https://github.com/github/semantic.git synced 2025-01-03 04:51:57 +03:00
Code Issues Projects Releases Wiki Activity

Parameterize runDistribute by the interpreter.

Browse Source
This commit is contained in:
Rob Rix 2018-04-04 10:59:34 -04:00
parent bf237d6680
commit a3489be5f7
1 changed files with 5 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

10
src/Semantic/Task.hs
View File

@ -189,12 +189,12 @@ runTaskWithOptions options task = do
run options logger statter = run' run options logger statter = run'
where where
run' :: Task a -> IO (Either SomeException a) run' :: Task a -> IO (Either SomeException a)
run' = runM . runError . flip runReader statter . flip runReader logger . runTelemetry . flip runReader options . runTaskF . runDistribute run' = runM . runError . flip runReader statter . flip runReader logger . runTelemetry . flip runReader options . runTaskF . runDistribute (run' . unwrapTask)
runDistribute :: Members '[Exc SomeException, IO] effs => Eff (Distribute WrappedTask ': effs) a -> Eff effs a runDistribute :: Members '[Exc SomeException, IO] effs => (forall output . task output -> IO (Either SomeException output)) -> Eff (Distribute task ': effs) a -> Eff effs a
runDistribute = interpret (\ task -> case task of runDistribute run = interpret (\ task -> case task of
Distribute tasks -> liftIO (Async.mapConcurrently (run' . unwrapTask) tasks) >>= either throwError pure . sequenceA . withStrategy (parTraversable (parTraversable rseq)) Distribute tasks -> liftIO (Async.mapConcurrently run tasks) >>= either throwError pure . sequenceA . withStrategy (parTraversable (parTraversable rseq))
Bidistribute tasks -> liftIO (Async.runConcurrently (bitraverse (Async.Concurrently . run' . unwrapTask) (Async.Concurrently . run' . unwrapTask) tasks)) >>= either throwError pure . bisequenceA . withStrategy (parBitraversable (parTraversable rseq) (parTraversable rseq))) Bidistribute tasks -> liftIO (Async.runConcurrently (bitraverse (Async.Concurrently . run) (Async.Concurrently . run) tasks)) >>= either throwError pure . bisequenceA . withStrategy (parBitraversable (parTraversable rseq) (parTraversable rseq)))
parBitraversable :: Bitraversable t => Strategy a -> Strategy b -> Strategy (t a b) parBitraversable :: Bitraversable t => Strategy a -> Strategy b -> Strategy (t a b)
parBitraversable strat1 strat2 = bitraverse (rparWith strat1) (rparWith strat2) parBitraversable strat1 strat2 = bitraverse (rparWith strat1) (rparWith strat2)