question: public THLParallelReadQueue ( int taskId , int maxSize , int maxControlEvents , long startingSeqno , int syncInterval , ReplDBMSHeader lastHeader , AtomicIntervalGuard < ? > intervalGuard ) { this . taskId = taskId ; this . readSeqno = startingSeqno ; this . syncInterval = syncInterval ; this . intervalGuard = intervalGuard ; this . eventQueue = new LinkedBlockingQueue < ReplEvent > ( maxSize ) ; this . watchPredicates = new LinkedList < WatchPredicate < ReplDBMSHeader > > ( ) ; this . controlQueue = new LinkedList < ReplControlEvent > ( ) ; if ( lastHeader == null ) { this . lastHeader = new ReplDBMSHeaderData ( startingSeqno - 1 , ( short ) 0 , true , "dummy" , - 1 , "dummy" , "dummy" , new Timestamp ( System . currentTimeMillis ( ) ) , 0 ) ; } else { this . lastHeader = lastHeader ; } }
target:  Instantiates a new read queue.