Guest User

Untitled

a guest
May 23rd, 2018
80
0
Never
Not a member of Pastebin yet? Sign Up, it unlocks many cool features!
text 0.82 KB | None | 0 0
  1. import java.util.concurrent.ArrayBlockingQueue;
  2. import java.util.concurrent.BlockingQueue;
  3.  
  4. public class Test {
  5. private BlockingQueue<String> queue;
  6.  
  7. public Test(){
  8. queue = new ArrayBlockingQueue<String>(10);
  9.  
  10. for (int i=0 ;i<10 ;i++ ){
  11. queue.add(new String("" + i));
  12. }
  13.  
  14. // Create a set of worker threads
  15. Worker[] workers = new Worker[2];
  16. for (int i = 0; i < workers.length; i++) {
  17. workers[i] = new Worker();
  18. workers[i].start();
  19. }
  20.  
  21. }
  22.  
  23. private class Worker extends Thread {
  24.  
  25. public void run() {
  26. while (true) {
  27. String item = queue.poll();
  28. try {
  29. Thread.sleep(1000);
  30. } catch (InterruptedException e) {
  31. e.printStackTrace();
  32. }
  33. System.out.println("item:" + item);
  34. }
  35. }
  36. }
  37.  
  38. public static void main(String[] args) {
  39. new Test();
  40. }
  41. }
Add Comment
Please, Sign In to add comment