在同时活动的多个进程中更新 Java 中的数据

我正在创建一个带有传感器的令牌环，其中每个传感器都是一个独立的进程。当我启动传感器时，它与网关通信并获取系统上已有的实际传感器的列表。 问题是，每次我开始一个新进程时，我希望每个现有的传感器都能获取更新的列表，以便了解其他传感器已被添加，并且该列表不再是它们拥有的列表，而是一个新的更新列表。（所以假设进程必须始终具有相同的列表）。我使用一个我称之为的服务器serverSocket它监听消息。我可以让服务器了解列表已更改，但我不能做的是如何更改列表的值sensorList发现在我的SensorClient类，要更新吗？在下面的代码中，我展示了我在做什么，但是sensorList一直是旧的，没有更新：/有人可以帮助我吗？谢谢 ：）

SensorClient，我在其中启动新的过程传感器

 public class SensorClient {
    public static void main(String[] args) throws Exception {
    Sensor sensor = new      Sensor(type,identificator,portnumber,ipnumber,gatewayAddr,timestamp);
     Gson gson = new Gson();
      String message = gson.toJson(sensor);
       Client c = Client.create();
       WebResource r = c.resource("http://localhost:9999/gateway/");
       ClientResponse response = r.path("sensors/add").type(MediaType.APPLICATION_JSON).accept(MediaType.APPLICATION_JSON).post(ClientResponse.class, message);

 if (response.getStatus() == 200) {
       repeat = false;
      Type collectionType = new TypeToken<ArrayList<Sensor>>(){}.getType();
     ArrayList<Sensor> sensorList =    gson.fromJson(response.getEntity(String.class), collectionType);
     System.out.println("Starting the sensor ...");
     System.out.println("Push exit when you want to delete the sensor!");
     int position = 0;
     for(int i = 0; i< sensorList.size();i++){    if(sensorList.get(i).getIdentificator().equalsIgnoreCase(sensor.getIdentificator()) ) position = i;
}
sensors.Sensor.simulation(type, identificator);// special thread for sensors simulations
createSensor.getInstance().setPrevNextWhenAdd(position,sensorList);

serverSocket serverSocket = new serverSocket(portnumber,sensorList,position,sensorList.get(position).getNext());
 serverSocket.start();

StopSensor stopSensor = new StopSensor(identificator,portnumber,position,sensorList);
stopSensor.start();

oneSensor s = new oneSensor(portnumber,sensorList);
 s.start();
 } else {
          repeat = true;
          count +=1;
          System.out.println("Error. Wrong data! ");
                }
              }
            while (repeat );
        }
    }
                            }

服务器Socket线程

public class serverSocket extends Thread {
    public int port,nextPort;
    ArrayList<gateway.Sensor> sensorList;
    public static int position;
    public serverSocket(int port, ArrayList<gateway.Sensor> sensorList,int position,int nextPort) {
    this.port = port;
    this.nextPort=nextPort;
    this.sensorList= sensorList;
    this.position=position;}
    public void run() {
            ServerSocket welcomeSocket;
            Socket connectionSocket;
            try {
                welcomeSocket = new ServerSocket(port);
                while (true) {
                    connectionSocket = welcomeSocket.accept();

                    receivedMessages thread = new receivedMessages(connectionSocket,sensorList,position,nextPort);
                    thread.start();
                }
            } catch (IOException e) {
                e.printStackTrace();
                System.err.println("Error!!!!!!!!!");
            }
        }
}

receiveMessages 线程

    public class receivedMessages extends Thread {

        private BufferedReader inFromClient;
        private Socket connectionSocket;
        ArrayList<gateway.Sensor> sensorList;
        int position,nextPort;
        public receivedMessages(Socket socket, ArrayList<gateway.Sensor> sensorList,int position,int nextPort){
                connectionSocket = socket;
                this.sensorList=sensorList;
                this.position=position;
                this.nextPort=nextPort;
 try {
      inFromClient = new BufferedReader( new InputStreamReader(connectionSocket.getInputStream()));
                   } catch (IOException e) { e.printStackTrace(); }
                }
@Override
public void run() {

try {

     String message = (inFromClient.readLine().toString());
     if (message.startsWith("Next") || message.startsWith("Previous")) {
     System.out.println(message);
     } else if (message.startsWith("The")) {
     System.out.println(message);                        createSensor.getInstance().setPrevNextWhenDelete(position, sensorList);
     } else  {// i receive the message that the list has changed
     System.out.println(message);
     sensorList = createSensor.getInstance().getSensorList();
     System.out.println("Updated " + sensorList);}

此类具有网关在发出请求时用于注册传感器的方法

public class createSensor {

  private static createSensor instance = null;
  private ArrayList<Sensor> sensor = new ArrayList<>();
  public int position, prevPosition, nextPosition, prevPort, nextPort;

 private createSensor() { } 
 public static synchronized createSensor getInstance() { 
        if (instance == null) {
            instance = new createSensor();
        }
        return instance;
    }
 public synchronized ArrayList insertSensor(String type, String identificator, int port, String id, String gatwayAddr, long timestamp) throws IOException {

sensor.add(new Sensor(type, identificator, port, id, gatwayAddr, timestamp));
                    return new ArrayList<>(sensor); // 
                }
            }
 public synchronized boolean hasMeasurements() {
     while (InnerBuffer.getInstance().emptyInnerBuffer())
                    return false;
                return true;
            }

public synchronized void setPrevNextWhenDelete(int position,ArrayList<Sensor> sensorList) throws IOException {
        //code
            }

public synchronized ArrayList<Sensor> getSensorList() {
                return new ArrayList<>(sensor);
            }

public synchronized int size() {
          return sensor.size();
            }

 public synchronized String returnRecentMeasurement (String id){
   String recentMeasurement=null;
      for (Sensor sensori : sensor) {
       if (sensori.getIdentificator().equalsIgnoreCase(id))
          recentMeasurement= InnerBuffer.getInstance().returnRecentMeasurements(id);
                    else
                        recentMeasurement = null;}
                return recentMeasurement;
            }
public synchronized void  setPrevNextWhenAdd() throws IOException {  //some other code where int position, prevPosition, nextPosition, prevPort, nextPort get their values. }}