Я написал простую программу на Java, которая помогает играть с потоками и пулами потоков для выполнения определенных задач. В моей программе есть объекты класса TheObject
, которые должны иметь какую-то обработку (в данном случае просто задержку сна и распечатку их полей).
TheObject
объекты помещаются в очередь, из которой WorkerThread
s извлекают их и обрабатывают.
Я создал класс Manager
, который инициализирует TheObjects
и WorkerThread
. Я получаю странный результат, когда запускаю его; Вместо того, чтобы потоки отключали работу, все обрабатывает один поток! Почему это происходит? Как заставить потоки разделять рабочую нагрузку?
Это результат:
--------------------------------------------
alfred a 0
Thread-0
--------------------------------------------
bob b 1
Thread-0
--------------------------------------------
carl c 2
Thread-0
--------------------------------------------
dave d 3
Thread-0
--------------------------------------------
earl e 4
Thread-0
--------------------------------------------
fred f 5
Thread-0
--------------------------------------------
greg g 6
Thread-0
--------------------------------------------
harry h 7
Thread-0
--------------------------------------------
izzie i 8
Thread-0
--------------------------------------------
jim j 9
Thread-0
--------------------------------------------
kyle k 0
Thread-0
--------------------------------------------
Larry L 1
Thread-1
--------------------------------------------
Michael M 2
Thread-1
--------------------------------------------
Ned N 3
Thread-0
--------------------------------------------
Olaf O 4
Thread-0
--------------------------------------------
Peter P 5
Thread-0
--------------------------------------------
Quincy Q 6
Thread-0
--------------------------------------------
Raphael R 7
Thread-0
--------------------------------------------
Sam S 8
Thread-0
--------------------------------------------
Trixie T 9
Thread-0
Код:
Классы:
- Управляющий делами
- Объект
- TheObjectQueue
- WorkerThread
Менеджер
public class Manager {
public static void main(String[] args) throws InterruptedException {
TheObjectQueue queue = new TheObjectQueue();
//Create Objects
int numberOfInitialObjects = 10;
String[] arrayOfNames = {"alfred", "bob", "carl", "dave", "earl", "fred", "greg", "harry", "izzie", "jim"};
//char[] arrayOfChars = {'a', 'b', 'c', 'd', 'e', 'f', 'g', 'h', 'i', 'j'};
//int[] arrayOfNums = {1, 2, 3, 4, 5, 6, 7, 8, 9, 10};
for (int i = 0; i < numberOfInitialObjects; i++){
TheObject anObject = new TheObject(arrayOfNames[i], arrayOfNames[i].charAt(0), i);
queue.addToQueue(anObject);
}
int numberOfThreads = 2;
for (int i = 0; i < numberOfThreads; i++){
WorkerThread workerThread = new WorkerThread(queue);
workerThread.start();
}
try {
Thread.sleep(5000);
} catch (InterruptedException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
String[] arrayOfNames2 = {"kyle", "Larry", "Michael", "Ned", "Olaf", "Peter", "Quincy", "Raphael", "Sam", "Trixie"};
for (int i = 0; i < numberOfInitialObjects; i++){
TheObject anObject = new TheObject(arrayOfNames2[i], arrayOfNames2[i].charAt(0), i);
queue.addToQueue(anObject);
}
}
}
TheObject
public class TheObject {
private String someName;
private char someChar;
private int someNum;
public TheObject(String someName, char someChar, int someNum) {
super();
this.someName = someName;
this.someChar = someChar;
this.someNum = someNum;
}
public String getSomeName() {
return someName;
}
public char getSomeChar() {
return someChar;
}
public int getSomeNum() {
return someNum;
}
}
TheObjectQueue
import java.util.LinkedList;
public class TheObjectQueue {
private LinkedList<TheObject> objectQueue = null;
public TheObjectQueue(){
objectQueue = new LinkedList<TheObject>();
}
public LinkedList<TheObject> getQueue(){
return objectQueue;
}
public void addToQueue(TheObject obj){
synchronized (this) {
objectQueue.addFirst(obj);
this.notify();
}
}
public TheObject removeFromQueue(){
synchronized (this) {
TheObject obj = objectQueue.removeLast();
return obj;
}
}
public int getSize(){
return objectQueue.size();
}
public boolean isEmpty(){
return objectQueue.isEmpty();
}
}
WorkerThread
import java.util.Random;
public class WorkerThread extends Thread{
private TheObjectQueue queue;
public WorkerThread(TheObjectQueue queue){
this.queue = queue;
}
public void process(TheObject obj){
//Stall for a random amount of time
Random random = new Random();
int randomInt = random.nextInt(3)*1000;
try {
Thread.sleep(randomInt);
} catch (InterruptedException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
//Begin Printing
System.out.println("--------------------------------------------");
System.out.print(obj.getSomeName());
System.out.print(" ");
System.out.print(obj.getSomeChar());
System.out.print(" ");
System.out.println(obj.getSomeNum());
System.out.println(this.getName());
}
@Override
public void run() {
while(true){
synchronized (queue) {
while(queue.isEmpty()){
try {
queue.wait();
} catch (InterruptedException e) {
e.printStackTrace();
}
}
TheObject objToDealWith = queue.removeFromQueue();
process(objToDealWith);
super.run();
}
}
}
}