Выполнение Java-кода сети до получения объекта

Question

У меня есть Java-игра, в которой используется сеть, и у меня есть клиент (используя Socket), который извлекает объекты из ObjectInputStream, работающие в своем потоке.

Client.java От:

 Object input = null; 
     while(true) { 
      input = in.readObject(); 
      if(input != null) { 
       listener.gotObject(input); 
      } 
     } 

Это работает очень хорошо. Объект получает и передается слушателю, который является классом, связанным с моим основным классом GameApp.

От слушателя (NetControl.java):

public void gotObject(Object o) { 
    System.out.println(o); 
    app.gotObject(o); 
} 

«приложение» является экземпляр, который обрабатывает все новые объекты, полученные и сделок с ними.

Из приложения (GameApp.java) (Edit: неабстрактный CardGameApp.java дает больший контекст):

public void gotObject(Object o) { 
    // select instance: 
    if(o instanceof GameList) { 
     GameList gameList = (GameList) o; 
     System.out.println("gamelist: " + gameList); 
     this.lobbyControl.gotGameList(gameList); 
    } 
} 

Я запустить этот код в отладчике, один шаг за один раз, и это работает отлично. Когда я запускаю это нормально, хотя, я получаю пустой указатель (выход следующим образом :)

Game ID: 0. Name: game1. Players: 1/1. // the object, as it is printed in Client.java 

gamelist: Game ID: 0. Name: game1. Players: 1/1. // the object, as it is printed again in GameApp.java 

Exception in thread "Thread-1" java.lang.NullPointerException 
at com.lgposse.game.app.GameApp.gotObject(GameApp.java:61) 
at com.lgposse.game.net.NetControl.gotObject(NetControl.java:47) 
at com.lgposse.net.client.Client.run(Client.java:49) 

Теперь я вижу объект печатаемого дважды, так что я знаю, что это было получено ... но я получаю null указатель.

Я добавил функцию сна в середине функции:

else if(o instanceof GameList) { 
     GameList gameList = (GameList) o; 
     System.out.println("gamelist: " + gameList); 
     try { 
      Thread.sleep(1000); // sleep 100 still gave null pointer 
     } catch (InterruptedException e) {} 
     this.lobbyControl.gotGameList(gameList); 
    } 

и установка его спать на некоторое время, все это наконец-то работал.

Любая идея, почему мне нужно спать в этой теме? Есть ли что-то, что я должен делать по-другому? Я не уверен, почему я смог напечатать объект, пока он все еще считается нулевым.

Редактировать: добавлен контекст.

Answer 1

Похоже, lobbyControl является null, а не gameList. Если gameList были нулевыми, вершиной стека был бы метод gotGameList(), а не gotObject().

Если сон помогает решить проблему, тогда вы должны манипулировать членом lobbyControl без надлежащих гарантий параллелизма. ObjectInputStream не вернет объект, пока он не будет полностью прочитан из потока, поэтому ваша проблема не имеет ничего общего с тем, что он не полностью прочитал объект.

---

Update: Я не могу следовать весь код, но это, кажется, что ссылка на объект строится просочилась в потоке (client в NetControl), который запускается перед конструктором завершается. Если это так, это очень, очень плохо. Вы должны Никогда позволяют частично сконструированному объекту стать видимым для другого потока.

Answer 2

Ну, я начну, сказав, что опубликованные фрагменты кода помогают проиллюстрировать проблему, но я не думаю, что полная картина нарисована. Я бы попросил немного больше кода, чтобы помочь получить полный контекст.

Это, как говорится, я бы предложить следующие рекомендации:

1. Не опирайтесь на Java встроенный в сериализации объекта. Это хорошо и проста в использовании, но может быть очень неустойчивой и подвержена ошибкам во время работы. Я бы предложил сериализацию пользовательских объектов и десериализацию .

2. В зависимости от объема вашей игры NIO может быть нетривиальным выбором. Если вы придерживаетесь обычного ввода-вывода, то убедитесь, что у есть твердотельный менеджер потоков на месте, чтобы правильно обрабатывать потоки , имеющие дело с гнездом IO.

.. без дополнительного кода, это самое лучшее, что я могу предложить.

Answer 3

Просто для улучшения моего комментария ... Когда мне нужно подождать, пока закончится один или несколько потоков, мне нравится использовать java.util.concurrent.CountDownLatch. Его очень просто:

//game class 
public class DummyGame 
{ 
    CountDownLatch signal; 

    public DummyGame(CountDownLatch signal) 
    { 
     this.signal = signal; 
    } 
    public void run() 
    { 
     doLogic(); 
     signal.countDown(); 
    } 
} 

//game controller class 

public void run() 
{ 
    while (! gameOver) 
    { 
     CountDownLatch signal = new CountDownLatch(1); //wait one thread to finish 
     new thread(newGame(signal)).start(); 

     //wait for game run() to finish 
     signal.await(); 

     updateInterface(); 
    } 
} 

Это просто идея, надеюсь, что это поможет.