以下程序最终进入旋转循环。我不知道可能是什么原因。如果有人可以帮助我，我会非常高兴。在下面的代码中，我有一个发送方，它将一些数据多播到组224.0.1.20:64的接收方。发送者等待对象val的r变量和r1类的ThreadManager发送数据。并且在退出之前，等待相同实例的val1更改后关闭。我之前尝试过join()。但这也不起作用。如下所示，发送方等待有时代码正确执行并给出输出，但有时循环。
package com.test;
import java.io.IOException;
import java.net.DatagramPacket;
import java.net.InetAddress;
import java.net.MulticastSocket;
import java.util.Date;
public class Test {
public static void main(String[] args) throws IOException, InterruptedException {
Sender s = new Sender(64);
ThreadManager r = new ThreadManager();
ThreadManager r1 = new ThreadManager();
r.start();
r1.start();
//Thread.currentThread().setPriority(1);
while(r.val1 != true || r1.val1 != true){
>// I know this is wrong way to wait, but this is just a test
>// appln, so I used polling.
//Thread.currentThread().sleep(1);
//System.out.println(r.val1 || r1.val1);
}
System.out.println("going to send..");
s.send("kaushik");
while((r.val != true || r1.val != true) || (r.isAlive() && r1.isAlive())){
// same here..
System.out.println(r.val || r.val1);
//Thread.sleep(1000);
}
System.out.println("closing..");
}
}
class ThreadManager extends Thread{
public boolean val = false;
public boolean val1 = false;
@Override
public void run() {
// TODO Auto-generated method stub
Reciever r;
try {
r = new Reciever(64);
byte[] buf = new byte[65508];
System.out.println("Going. to be started...");
DatagramPacket packet = new DatagramPacket(buf, 65508);
val1 = true;
r.recieve(packet);
} catch (IOException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
val = true;
System.out.println(val+" Id :"+Thread.currentThread().getId());
}
}
class Sender{
private MulticastSocket s;
public Sender(int port) throws IOException{
s = new MulticastSocket(port);
s.joinGroup(InetAddress.getByName("224.0.1.20"));
}
public void send(String data) throws IOException{
System.out.println("Server"+s.getLocalPort());
DatagramPacket packet = new DatagramPacket(data.getBytes(), data.getBytes().length,InetAddress.getByName("224.0.1.20"),s.getLocalPort());
s.send(packet);
System.out.println("server"+s.getRemoteSocketAddress());
s.close();
}
}
class Reciever{
private MulticastSocket s;
public Reciever(int port) throws IOException{
s = new MulticastSocket(port);
s.joinGroup(InetAddress.getByName("224.0.1.20"));
}
public void recieve(DatagramPacket packet) throws IOException{
s.receive(packet);
byte recv[] = new byte[65508];
System.arraycopy(packet.getData(), 0, recv, 0, packet.getData().length);
//System.out.println(new String(recv));
System.out.println(new String(recv).trim() + "Date : "+ new Date() + "length :" +new String(recv).trim().length());
s.leaveGroup(InetAddress.getByName("224.0.1.20"));
s.close();
}
}
输出：
1。
要去开始...
要去开始...
要发送..
服务器64
服务器为空
2014年11月26日星期三美国东部时间11:19:09长度：7
真实ID：9
2014年11月26日星期三美国东部时间11:19:09长度：7
真实编号：10
**请注意，我在ThreadManager类中将val1和val设置为true。在上面的输出中，val1对于r1和r实例都设置为true，但是程序仍未终止。
最佳答案
这不是僵局。 UDP是不可靠的，如果您的行李丢失了，收货人将等待数据，看起来像是“死锁”。最好为接收者设置一个“超时”。
在这里，您将r.val1共享给主线程，需要使用“ volatile”使val1在其值更改时立即对主线程可见，volatile也可以防止JIT或CPU进行积极的优化。
public volatile boolean val1 = false;
请注意在此处使用synced，synced（this）不起作用，因为这意味着synchronized（r）和synchronized（r1），它们是不同的“锁”。如果要保护线程间的共享变量，请使用相同的“锁”。
关于java - 组播期间程序旋转，我们在Stack Overflow上找到一个类似的问题：https://stackoverflow.com/questions/27142182/