Pobieranie informacji z serwera java socket

Question

Witam,
posiadam klienta oraz serwer schematyczna komunikacja wygląda tak:

--- CLIENT ---
Client->wyślijNaServer("podajMiWielkośćListy")->Server;

 
--- SERWER ---
if(odebrane.equals("podajMiWielkośćListy"))
       Server->wyslijDoClienta("Wielkość tablicy wynosi: 20")->Client;

--- Nowa Inna Klasa (Main) ---
if(toCoOtrzymałClientOdSerwera < 10)

     print("Dołączyłeś do serwera")
 else
     print("Maksymalna ilość osób")

Odbieranie Clienta i Serwera jest obsługiwane w nowym wątku, tu nasuwa się pytanie jak w prosty sposób przypisać wartość do zmiennej, aby móc sprawdzić warunek? Aby w zmiennej było już zapisane to co powinno być. Doradziłby ktoś coś? :)

Pozdrawiam ;)

Answer 1

Każdy socket ma coś takiego jak input stream i output stream. Musisz pobrać ze zmiennej socket output stream i używając metod streamu pobrać wysłane dane.

Comments

Tak, potrafię odbierać i wysyłać dane. Problem polega na tym, że gdy coś client odbierze ustawia wartość zmiennej np. int x = OdebranaWartośćOdSerwera;

Ale gdy wykonam metodę getX() w innej klasie, dostaje nieprawidłową wartość, gdyż wątek jeszcze nie zdążył jej ustawić tak myślę. ;(

---

Jeśli uważasz że problem jest z wątkami to musisz je jakoś zsynchronizować. Jeśli masz jeden wątek odbierający i chcesz aby twój główny wątek poczekał na odbiór to możesz po stworzeniu wątku przyczepić się do niego czekając na jego skończenie.

Możesz do tego użyć np join()

---

No ale wątek odbierania nigdy się nie skończy. ;(

---

To w takim razie musisz użyć trochę trudniejszej synchronizacji.W wątku w którym pobierasz możesz założyć locka na jakimś obiekcie i zwolnić go po pobraniu wartosci.  W wątku gdzie chcesz użyć tej wartości możesz zsynchronizować się na tym obiekcie lock i poczekać aż blokada zostanie zwolniona.

---

Dzięki twoim wskazówką dodałem taki kod:

 private final CountDownLatch set = new CountDownLatch(1);

    public Boolean getValue() throws InterruptedException {
        set.await();
        return value;
    }
    
    public synchronized void setValue(Boolean value) {
        if (set.getCount() > 0) {
            this.value = value;
            set.countDown();
        }
    }

I gdy pobieram od razu wartość jest poprawna. :) Dzięki