Skip to content

Commit

Permalink
HDFS-16137.Improve the comments related to FairCallQueue#queues. (apa…
Browse files Browse the repository at this point in the history
…che#3226)

Co-authored-by: zhujianghua <zhujianghua@zhujianghuadeMacBook-Pro.local>
Reviewed-by: Viraj Jasani <vjasani@apache.org>
  • Loading branch information
2 people authored and Kiran Kumar Maturi committed Nov 24, 2021
1 parent 584a531 commit 66ef9d6
Showing 1 changed file with 7 additions and 2 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -25,6 +25,7 @@
import java.util.Iterator;
import java.util.AbstractQueue;
import java.util.HashMap;
import java.util.List;
import java.util.concurrent.BlockingQueue;
import java.util.concurrent.LinkedBlockingQueue;
import java.util.concurrent.Semaphore;
Expand Down Expand Up @@ -58,8 +59,12 @@ public class FairCallQueue<E extends Schedulable> extends AbstractQueue<E>

public static final Logger LOG = LoggerFactory.getLogger(FairCallQueue.class);

/* The queues */
private final ArrayList<BlockingQueue<E>> queues;
/**
* Save the queue data of multiple priority strategies.
* Usually the number of queue data and priority strategies saved
* is the same.
*/
private final List<BlockingQueue<E>> queues;

/* Track available permits for scheduled objects. All methods that will
* mutate a subqueue must acquire or release a permit on the semaphore.
Expand Down

0 comments on commit 66ef9d6

Please sign in to comment.