git.iko.soy/streamly
on 57e6232 help sign in
history ofsrc/Asyncly/AsyncT.hs
all commits
57e6232Add comment about applicativeHarendra Kumar ed22c1cminor fix use mempty instead of empty in Monoid foldHarendra Kumar e637b6ccleanupHarendra Kumar 6ce4d8aremove monad-control stuffHarendra Kumar f9f6c96rename queue variablesHarendra Kumar e2b2acdStart new worker when existing ones are slowHarendra Kumar a0e2a34Fix continuation of the push loop after pull is doneHarendra Kumar 86f575dsimplify pullworker codeHarendra Kumar 5db9315Simplify push codeHarendra Kumar 064bb7eSome simplificationsHarendra Kumar bdaefb3Reuse threads instead of creating fresh every timeHarendra Kumar e8a7463Use TBQueue instead of an unbounded channelHarendra Kumar b3faafaSolve the problem of last dispatch blocking drainHarendra Kumar 1f01190Fix bug due to typo in pull finalizer and move itHarendra Kumar d8c399eImplement tracking and killing of child threadsHarendra Kumar 36ecdf8Perf - do not save pending work in the contextHarendra Kumar 6ec80a0Fix draining of threads (serial instead of parallel)Harendra Kumar 04fef4fMove a function in dep orderHarendra Kumar 09283c4Implement pull based concurrency rate controlHarendra Kumar b1ee90eAdd the yield APIHarendra Kumar 500d889Simplify push-pull split, fix monoid instanceHarendra Kumar b2faaf9remove a couple of stale commentsHarendra Kumar b38be3aReduce channel communication for short tasksHarendra Kumar 91a6ceeSimplify pushHarendra Kumar 9b2ca30Add the "for" parallel API and change "each" to serialHarendra Kumar 63f965acleanup Monoid instanceHarendra Kumar 6ea73b3Cleanup and refactor threading stuffHarendra Kumar e874ecfRemove quadratic complexity due to serially-in-seriallyHarendra Kumar 550eed4Make monoid instance append two computations in orderHarendra Kumar ef006c8Implement fork for Alternative instanceHarendra Kumar c9b9ab3Pass context directly, removing the use of State monadHarendra Kumar f4cce2fSeparate the bind and <|> semantics for parallelismHarendra Kumar bb5a74dSome cleanupsHarendra Kumar eca7d81Remove redundant composition primitivesHarendra Kumar a20c180Some cleanupHarendra Kumar c1f0a86Continuation based implementationHarendra Kumar 7e8209eSeparate the State layer from AsyncT layerHarendra Kumar 4d7024fInitial poc of lazy streamingHarendra Kumar c49732aMove the each primitive to right placeHarendra Kumar 4d4894cMove the thread contol primitive to threads moduleHarendra Kumar 3c7a92aMove around some codeHarendra Kumar 0d9243fSeparate the threadstate management layerHarendra Kumar 3ed5abcAdd some more SPECIALIZE and INLINE pragmasHarendra Kumar ce6719aMore SPECIALIZE and CAS for atomicmodifyHarendra Kumar b7d651fSPECIALIZE monad, alternative and each for IOHarendra Kumar 9ec9c52add noinline pragma for bindHarendra Kumar e1fc30aRemove additional binds, change continuations modelHarendra Kumar 59c0bacChange foldl to foldr in "each"Harendra Kumar d64225fReorganize code top to bottom in dependency orderHarendra Kumar 1be7567Remove redundant unsafeCoerceHarendra Kumar