1 5 package org.exoplatform.test.web; 6 7 13 public class WorkerThread extends Thread { 14 private Tasks tasks_ ; 15 16 public WorkerThread(ThreadGroup group, String name, Tasks tasks) { 17 super (group, name) ; 18 tasks_ = tasks ; 19 } 20 21 public WorkerThread() { 22 super() ; 23 } 24 25 public void setTasks(Tasks tasks) { tasks_ = tasks ; } 26 27 public void run() { 28 boolean availableTask = true ; 29 while(availableTask) { 30 if(isInterrupted()) return ; 31 Runnable task = tasks_.getNextTask() ; 32 if (task != null) { 33 task.run() ; 35 } else { 36 availableTask = false ; 37 } 38 } 39 } 40 } 41 | Popular Tags |