spacepaste

Paste details

reply | raw | toggle line wrapping

service.lua

  1.  
  2. local event = require('event')
  3. local s = require('serialization').serialize
  6. local service = {}
  8. local function step_coroutine(c)
  9. local t = {coroutine.resume(c)}
  10. if not t[1] then
  11. if coroutine.status(c) == 'dead' then
  12. return false
  13. else
  14. print(debug.traceback(c))
  15. error(t[2], 0)
  16. end
  17. end
  18. return true
  19. end
  21. function service.periodic(period, f, env)
  22. local t
  23. local function service_coroutine()
  24. while true do
  25. local c = coroutine.create(f)
  26. while true do
  27. if not step_coroutine(c) then
  28. break
  29. end
  30. coroutine.yield()
  31. end
  32. end
  33. end
  34. function env.start()
  35. if t then
  36. return
  37. end
  38. local c = coroutine.create(service_coroutine)
  39. local function step()
  40. step_coroutine(c)
  41. end
  42. t = event.timer(period, step, math.huge)
  43. end
  44. function env.stop()
  45. if not t then
  46. return
  47. end
  48. event.cancel(t)
  49. end
  50. function env.status()
  51. if t then
  52. print('running')
  53. else
  54. print('stopped')
  55. end
  56. end
  57. end
  59. return service
  60.  

example-service.lua

  1.  
  2. local service = require('service')
  4. -- [...]
  6. function tick()
  7. clear_whole_db()
  8. export_relevant_items()
  9. end
  11. service.periodic(10, tick, _ENV)
  12.  
Powered by spacepaste. Paste removal.