messages imellem threads

Du sender en reference til de data der skal deles med over i constructoren
til thread klassen, constructoren gemmer den og så kan run metode bruge
den reference.

Og ved brug af:

synchronized(variabel) {
  ...
}

omkring kritiske kode sektioner undgår du samtidigheds problemer.

Har prøvet noget i den retning men ved ikke om det er helt rigtigt

class ClientListenThread extends Thread
{
    public Messages messages;
    public ClientListenThread(Socket socket, Messages msgs)
    {
        messages = msgs;  // her skulle messages så blive gemt
        this.socket = socket;
        try
        {
            socketIn= new BufferedReader(new InputStreamReader(socket.getInputStream()));
        }
        catch(IOException e)
        {
        }
    }

    public synchronized void run()
    {
        String input;
        try
        {
            while(true)
            {
                input = socketIn.readLine();        // Just take the input
                aMsg = aMsg.stringAsMessage(input);
                synchronized(messages) {
                    messages.putMessage(aMsg);
                }
            }
        }
        catch(IOException e)
        {
        }
    }
   

Når jeg så starter tråden gør jeg det med:
            receiveThread = new ClientListenThread(socket, messages);
            receiveThread.start();


I denne funktion der ligger i min "hovedklasse" skal jeg så bruge og slette lidt i de messages:
    public synchronized boolean getAMessage()
    {
        if(messages.size()>0)
        {
            aMsg = messages.getMessage(0);
            messages.removeElementAt(0);
            return true;
        }
        else
            return false;
    }

det er garanteret ikke det store der er galt.. bare mig der gør det forkert :/

/tand

Den overordnede logik ser OK ud.

Du mangler at erklære nogle variable.

aMsg = aMsg.stringAsMessage(input); forstår jeg ikke

Og så skal synkroniseringen  muligvis "finjusteres"

Okay. variablerne er erklærede :) den aMsg = aMsg.stringAsMessage(input); er nok også lidt "dumt" lavet.. det er for at jeg kan sende en message gennem sockets. den burde så nok ikke lige have være lavet i Message classen :)

Men prøv og se hvordan det virker.

hmm jeg får dem ikke overført.. hvis du lige vil se erklæringerne kommer de her:
her er de i "hovedklassen:
    static Messages messages;
    static Message aMsg;

og i threaden:
    public Messages messages;
    private Message aMsg;

der er garanteret noget der der er galt :) kan bare ikke lige helt overskue det

nåh du ved det åbenbart heller ikke ???

Jeg har ikke engang forstået hvad fejlen er.

fejlen er at den messages jeg har i hovedklassen og den jeg har i tråden ikke er den samme.. åbenbart.. :(

Jeg har prøvet alt muligt nu.. men uden held
/tand

Vi kommer næppe videre uden at se noget mere kode

Okay.. Skal smider lige koden her så:

public class ChatApplet extends java.applet.Applet{
    static String chatname;
    static long chatid;
    static String serverip;
    static Socket socket;
    static BufferedWriter socketOut;
    static ClientListenThread receiveThread;
    static Messages messages = new Messages();
    static Message aMsg;

   
    public boolean connect()
    {
        try
        {
            socket = new Socket(InetAddress.getByName(serverip),1000);
            socketOut = new BufferedWriter( new OutputStreamWriter(socket.getOutputStream()));
            receiveThread = new ClientListenThread(socket);
            receiveThread.start();
            return true;
        }
       
        catch(IOException e)
        {
            System.err.flush();
            return false;
        }
    }
   
    public int getMessageType()
    {
        return aMsg.getMessageType();
    }
   
    public String getMessageFrom()
    {
        return aMsg.getMessageFrom();
    }
   
    public long getMessageFromID()
    {
        return aMsg.getMessageFromID();
    }
   
    public String getMessageTo()
    {
        return aMsg.getMessageTo();
    }
   
    public long getMessageToID()
    {
        return aMsg.getMessageToID();
    }
   
    public String getMessageText()
    {
        return aMsg.getMessageText();
    }
   
   
    public static synchronized boolean getAMessage()
    {
        if(messages.size()>0)
        {
            aMsg = messages.getMessage(0);
            messages.removeElementAt(0);
            return true;
        }
        else
            return false;
    }
   
    public void sendMessage(int type, String to, long toID, String text)
    {
        Message message = new Message(type, chatname, chatid, to, toID, text);
        String str = message.messageAsString();
        send(str);
    }
       
    private void send(String msg)
    {
        try
        {
            socketOut.write(msg);
            socketOut.newLine();
            socketOut.flush();
        }
        catch(IOException e)
        {
            System.err.println("ERROR: Could not send data: " +e);
        }
    }
   
    public void init()
    {
        chatname = getParameter("chatname");
        chatid = Long.parseLong(getParameter("chatid"));
        serverip = getParameter("server");
   
    }

}


import java.io.*;
import java.net.*;

class ClientListenThread extends Thread
{
    private BufferedReader socketIn;
    private BufferedWriter socketOut;
   
    private Socket socket;   
    static Messages messages;
    private Message aMsg;

    public ClientListenThread(Socket socket)
    {
        this.socket = socket;
        try
        {
            socketIn= new BufferedReader(new InputStreamReader(socket.getInputStream()));
        }
        catch(IOException e)
        {
        }
    }
   

    public synchronized void run()
    {
        String input;
        try
        {
            while(true)
            {
                input = socketIn.readLine();        // Just take the input
//                System.out.println(input);
                aMsg = aMsg.stringAsMessage(input);
                messages.putMessage(aMsg);
            }
        }
        catch(IOException e)
        {
        }
    }
   
   
}

Min ClientListenThread lytter efter beskeder fra serveren og smider dem ind på messages. ChatApplet skal så hvergang getAMessage() kaldes, ta den første message i rækken og lægger den over i aMsg. derfra kan jeg så få de enkelte værdier over i min javascript kode som også hører til. Jeg ved at selve min ChatApplet virker, da jeg har prøvet selv at lægge messages på listen og så hive dem ud derfra.

Jeg har snart prøvet alle mulige kombinationer og kan ikke få det til at virke.. håber du forstår hvad jeg mener.
Mvh
/Tand

Ja, men du sender jo ikke messages over i ClientListenThread constructor, så det
kan ikke overraske at du har to messages.

ooh.. sorry.. jow har prøvet med det også :(

receiveThread = new ClientListenThread(socket, messages);

og modtar den ovre i ClientListeThread:

public ClientListenThread(Socket socket, Messages messages)

mvh Tand

Og ClientListenThread constructor har:

this.messages = messages;

?

ja nu har den.. virker stadig ikke... :(

nåh.. har fundet ud af det alligevel ikke var der fejlen var.. :)
undskyld besværet.. det er min socket connection der går galt et eller andet sted istedet :(

Skal vi stoppe her eller skal vi også have det løst ?

Det sidste => vi skal have noget mere info

Jeg tror bare vi stopper her... :)hvis du vil ha dine point må er du velkommen :)

jo tak