我有一个想要相互交流的人的 HashMap,如下所示:
{zidane=[rooney, rooney, rooney, scholes, rooney], rooney=[scholes, messi, scholes], scholes=[ronaldo], ronaldo=[rooney, messi, scholes], messi=[zidane]}
在这里,密钥中的每个人都有自己的线程,他们将在其中向列表中的每个人发送消息并接收响应。
import java.util.*;
public class Master {
public Map callsMap = new HashMap<String, List>();
public static void main(String[] args){
Master m = new Master();
m.readFile();
Iterator<Map.Entry<String, List>> it = m.callsMap.entrySet().iterator();
while (it.hasNext()) {
Map.Entry<String, List> pair = it.next();
String caller = pair.getKey();
List receiverList = pair.getValue();
SubTasks st = new SubTasks(caller, receiverList);
Thread thread = new Thread(st);
thread.start();
//st.getMessage();
}
}
}
该类master
将为 HashMap 中的每个键迭代地创建一个线程。请注意,该readFile
方法只会从文本文件中读取并生成callsMap
我上面提到的输入(到变量中)。这对于这种情况并不是特别重要,所以我在这里省略了它。
我有一个SubTasks
扩展Thread
类并为每次交互创建消息的类。这个类不会创建任何额外的线程,而只是对它收到的调用者和接收者列表进行操作,如下所示:
import java.util.List;
public class SubTasks extends Thread {
private String caller;
private List receiverList;
private volatile String returnMessage;
SubTasks(String s, List l){
caller = s;
receiverList = l;
}
public void setMessage(String msg){
returnMessage = msg;
}
public String getMessage() {
return returnMessage;
}
@Override
public void run(){
for (int i = 0; i < receiverList.size(); i++) {
System.out.println(receiverList.get(i)+" received intro message from "+caller +" ["+System.currentTimeMillis()+"]");
returnMessage = caller+" received reply message from "+receiverList.get(i) +" ["+System.currentTimeMillis()+"]";
//setMessage(returnMessage);
System.out.println(returnMessage);
}
}
}
如果我在子线程中为所有 26 对打印消息,我会得到所需的输出。
zidane received message from messi [1592117172946]
rooney received message from ronaldo [1592117172946]
scholes received message from rooney [1592117172946]
rooney received message from zidane [1592117172946]
ronaldo received message from scholes [1592117172946]
messi received reply from zidane [1592117172989]
ronaldo received reply from rooney [1592117172989]
...
...
如何将这些消息传递到主线程(方法)并在那里打印而不是子线程?我尝试使用getter-setter
方法,但由于线程将随机执行,因此无法getter
正确调用方法。