线程的运行未看到其数组大小增加

Question

我目前正在做一个Java作业。我被要求创建一个基本的DNS服务器。有一个UDPSender类，它是一个监听端口53的线程。还有另一个线程叫做UDPManager。

UDPManager使用嵌套的可运行类启动线程，该类包含DatagramPacket的ArrayList。UDPSender聚合UDPManager，每当它接收到UDP数据包时，它都会将其发送给管理器，以便管理器将其添加到arrayList。

import java.net.DatagramPacket;
import java.util.ArrayList;
import java.util.HashMap;


public class UDPManager {
private UDPManagerRunnable manager;

public UDPManager(String hostsFile, String remoteDNS, boolean localResolution) {
    manager = new UDPManagerRunnable(hostsFile, remoteDNS, localResolution);
    new Thread(manager).start();
}

public void managePacket(DatagramPacket p) {
    manager.managePacket(p);
}

public void close() {
    manager.close();
}

private class UDPManagerRunnable implements Runnable {
    private ArrayList<DatagramPacket> packets;
    private HashMap<Integer, String> clients;
    private boolean localResolution;
    private boolean running;
    private String hostsFile;
    private String remoteDNS;

    public UDPManagerRunnable(String hostsFile, String remoteDNS, boolean localResolution) {
        packets = new ArrayList<DatagramPacket>();
        clients = new HashMap<Integer, String>();
        this.localResolution = localResolution;
        this.running = true;
        this.hostsFile = hostsFile;
        this.remoteDNS = remoteDNS;
    }

    public void managePacket(DatagramPacket p) {
        packets.add(p);
        System.out.println("Received packet. "+packets.size());
    }

    public void close() {
        running = false;
    }

    public void run() {
        DatagramPacket currentPacket = null;
        while(running) {
            if(!packets.isEmpty()) {
                currentPacket = packets.remove(0);
                byte[] data = currentPacket.getData();
                int anCountValue = data[Constant.ANCOUNT_BYTE_INDEX];
                if(anCountValue == Constant.ANCOUNT_REQUEST)
                    this.processRequest(currentPacket);
                else if(anCountValue == Constant.ANCOUNT_ONE_ANSWER)
                    this.processResponse(currentPacket);

            }
        }

    }

    private void processRequest(DatagramPacket packet) {
        System.out.println("it's a request!");
    }

    private void processResponse(DatagramPacket packet) {
        System.out.println("it's a response!");
    }

}

}

这是UDPManager。当System.out.println正确显示“Received packet”时，数据包被正确传输到管理器并且阵列的大小确实增加了。我遇到的问题是，在“run()”中，它看不到大小增加。奇怪的是，它在调试中工作得非常好。知道它为什么会这样吗？

非常感谢您的帮助。

Answer 1

您应该在访问或修改数据包时对其进行同步

Answer 2

问题是，您的第一个线程正在将新数据放入数据包变量中，但对于第二个线程，这是不可见的。您应该同步对数组的访问。

当您启动第二个线程时，所有变量都会被复制。第二个线程只处理副本。您需要同步对该变量的访问，以便其他线程可以看到更改。