PriorityQueue-based Scheduler

[Ron Shapiro]

I was experimenting with a Scheduler that allows callers to specify priorities for when actions should be executed. Not sure if this is something people are interested in getting into the official library or to keep as a standalone package. Nonetheless, I'd appreciate any feedback: https://github.com/ronshapiro/rxjava-priority-scheduler

Thanks,

--
Ron Shapiro

venmo.com/ronshapiro

[Shixiong Zhu]

A Scheduler.Worker should be a sequential Scheduler for executing actions on a single thread or event loop. But looks PriorityWorker in your codes will schedule Actions to multiple threads?

Best Regards,

Shixiong Zhu

[Ron Shapiro]

Is this closer to the Scheduler.Worker contract? https://github.com/ronshapiro/rxjava-priority-scheduler/blob/rs/scheduler-worker-pattern/src/main/java/me/ronshapiro/rx/priority/PriorityScheduler.java

Now, instead of the worker just submitting the action to the PriorityQueue and the Scheduler's ExecutorService looping infinitely, the worker submits to the queue and initiates the job to process the item from the queue.

--
Ron Shapiro

venmo.com/ronshapiro

[Shixiong Zhu]

I put my comments in https://github.com/ronshapiro/rxjava-priority-scheduler/commit/4f494499c456421433830e09e54e87018c7fca6b#diff-2572c21e7106ad62942efc32970be562L119

Best Regards,

Shixiong Zhu