Replace usage of PriorityBlockingQueue to simple PriorityQueue as execution of flowlet methods is single-threaded.