Advertisement
Not a member of Pastebin yet?
Sign Up,
it unlocks many cool features!
- public Task getNextTask(BlockingQueue<Task> queue){
- boolean interrupted = false;
- try{
- while(true){
- try{
- return queue.take();
- }catch(InterruptedException e){
- interrupted = true;
- //retry
- }
- }
- }finally {
- if(interrupted){
- Thread.currentThread().interrupt();
- }
- }
- }
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement