Advertisement
Guest User

Untitled

a guest
Sep 11th, 2013
81
0
Never
Not a member of Pastebin yet? Sign Up, it unlocks many cool features!
Java 0.49 KB | None | 0 0
  1.  
  2. ConcurentLinkedQueue<MyObject> queue;
  3.  
  4. ResultSet rs = /* SELECT href from LINKS */;
  5. while(rs.hasNext()) {
  6.   MyObject o = new MyObject(rs.next());
  7.   queue.add(o);
  8. }
  9.  
  10. /* create & start threads */
  11. for(int i = 0; i < 10; ++i) {
  12.   MyThread t = new MyThread(queue);
  13.   t.start();
  14. }
  15.  
  16. /* inside MyThread */
  17. void threadMethod() {
  18.   MyObject o = queue.poll();
  19.   if(o != null) {
  20.     /* process myobject */
  21.   } else {
  22.     System.out.println("no more items, thread shutting down.");
  23.   }
  24. }
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement