java - 多播期间程序旋转

Question

以下程序以自旋循环结束。我不知道可能是什么原因。如果有人能帮助我，我会非常高兴。在下面的代码中，我有一个发送方，它将一些数据多播到组 224.0.1.20:64 的接收方。发送方等待对象r的val变量和ThreadManager类的r1来发送数据。并且在退出之前等待相同实例的 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
服务器空
kaushik日期:2014 年 11 月 26 日星期三 11:19:09 EST 长度:7
真实ID:9
kaushik日期:2014 年 11 月 26 日星期三 11:19:09 EST 长度:7
真实 ID:10

** 请注意，我在 ThreadManager 类中将 val1 和 val 设置为 true**。在上面的输出中，r1 和 r 实例的 val1 都设置为 true，但程序仍然没有终止。

Answer 1

这不是死锁。 UDP不可靠，如果你的包在途中丢失，接收者将等待数据，这看起来像“死锁”。最好为接收器设置一个“超时”。

在这里，您将r.val1共享到主线程，您需要“volatile ”来让val1在其值发生变化时立即对主线程可见， volatile 还可以防止JIT或CPU的激进优化。

public volatile boolean val1  = false;

这里使用synchronized要小心，synchronized(this)不起作用，因为这意味着synchronized(r)和synchronized(r1)，它们是不同的“锁”。如果你想跨线程保护共享变量，请使用相同的“锁”。