typeable/wai
1
0
Fork 0
mirror of https://github.com/typeable/wai.git synced 2025-01-07 14:51:40 +03:00
Code Issues Projects Releases Wiki Activity

better naming.

Browse Source
This commit is contained in:
Kazu Yamamoto 2014-08-06 14:25:41 +09:00
parent cfe09ccf23
commit 99228319c4
1 changed files with 16 additions and 9 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

25
auto-update/Control/Reaper.hs
View File

@ -110,19 +110,26 @@ spawn settings stateRef = void . forkIO $ loop settings stateRef
loop :: ReaperSettings workload item -> IORef (Maybe workload) -> IO ()
loop settings@ReaperSettings{..} stateRef = do
threadDelay reaperDelay
wl1 <- atomicModifyIORef' stateRef get
wl2 <- reaperAction wl1
join $ atomicModifyIORef' stateRef (check wl2)
-- Getting the current jobs. Push an empty job to the reference.
wl <- atomicModifyIORef' stateRef swapWithEmpty
-- Do the jobs. A function to merge the left jobs and
-- new jobs is returned.
merge <- reaperAction wl
-- Merging the left jobs and new jobs.
-- If there is no jobs, this thread finishes.
join $ atomicModifyIORef' stateRef (check merge)
where
get Nothing = error "Control.Reaper.loop: unexpected Nothing (1)"
get (Just wl) = (Just reaperEmpty, wl)
swapWithEmpty Nothing = error "Control.Reaper.loop: unexpected Nothing (1)"
swapWithEmpty (Just wl) = (Just reaperEmpty, wl)
check _ Nothing = error "Control.Reaper.loop: unexpected Nothing (2)"
check wl2 (Just wl3)
| reaperNull wl4 = (Nothing, return ())
| otherwise = (Just wl4, loop settings stateRef)
check merge (Just wl)
-- If there is no workload, reaper is terminated.
| reaperNull wl' = (Nothing, return ())
-- If there are workloads, carry it out.
| otherwise = (Just wl', loop settings stateRef)
where
wl4 = wl2 wl3
wl' = merge wl
-- | A helper function for creating 'reaperAction' functions. You would
-- provide this function with a function to process a single work item and