TimerSet: cancel/reset task

[schmurfy]

In my use case I wanted to use a timer to act as a buffer:

• i queue data
• I create or reset a timer so that after X seconds an action is performed
• if the queue reach or exceed a specific size an action is done and the timer is canceled

After looking at the code TimerSet might be my friend using the Concurrent::timer() api passing my actor as an executor instead of using the global pool but what I am missing is a way to cancel/reset (as in restart its countdown).

PS: Looking through the source code is like wandering in a big fair with interesting things everywhere ;)

[schmurfy]

looking more into the source code there is another issue which is the one I mentioned in the mailing list: you cannot currently retrieve a reference to the "actor" from inside the object inside/below it.

[pitr-ch]

JFYI That is fixed in Actor implementation I am working on, see #73. It is in early stages but already working. I hope it will be ready in few weeks.

[schmurfy]

thanks for the pointer :)

[jdantonio]

@schmurfy I added TimeSet as a way to simplify some of the other high-level abstractions. I expected it to evolve so thank you for the input. @pitr-ch has some great ideas regarding more efficient timers so I'm happy to let him run with it and see it evolve.

[jdantonio]

@schmurfy Can I close this, or would you prefer to keep it open until @pitr-ch gets farther with his work?

[schmurfy]

I think there is no harm in keeping it open to track it.
If nothing else this might let someone know this is being worked on.

[jdantonio]

Being addressed in #299

[schmurfy]

nice ! Any rough idea on when it might land into a release ?

[jdantonio]

It will be in the next release, v0.9.0. I hope to finish the PR today.

[jdantonio]

PR #299, which implements these features, is now ready to be merged. The PR grew in scope and now included significant refactoring to TimerSet and ScheduledTask. It also include small enhancements to Future and Concurrent.timer.

[jdantonio]

Merged in #299. Will be released in v0.9.0.