UDP server sends thread application

[Koren3]

Hi, How can I do thread VlaknoPreposilaci?

package nserver;
 
import java.io.IOException;
import java.net.DatagramPacket;
import java.net.DatagramSocket;
import java.net.InetAddress;
import java.net.SocketException;
import java.util.ArrayList;
import java.util.Collections;
import java.util.List;
import java.util.logging.Level;
import java.util.logging.Logger;
 
/**
 *
 * @author Lolek
 */
 
public class Main {
 
    /**
     * @param args the command line arguments
     */
 
    public static void main(String[] args){       
 
            Port port = new Port();
            Adresa adresa = new Adresa();
            Preposilani prepos = new Preposilani();
            PreposilaniData pd = new PreposilaniData();
 
            VlaknoPrijimaci prijem = new VlaknoPrijimaci(5000, port, adresa, prepos,pd);
            VlaknoPreposilaci odesli = new VlaknoPreposilaci(port, adresa, prepos,prijem.server,pd);
 
 
     }    
  }
 
class VlaknoPrijimaci implements Runnable
{   
 
    private Port p;
    private Adresa a;
    private int getPort;
    private InetAddress getAddress;
    private Preposilani prepos; 
    private byte odeslana[] = new byte[256];
    private byte odeslanaData[] = new byte[256];
    private byte prijata[] = new byte[256];
    private PreposilaniData pd;
 
    DatagramSocket server;
 
 
    int port;   
    VlaknoPrijimaci(int port,Port p,Adresa a,Preposilani prepos, PreposilaniData pd)
    {   
        try {
            this.pd = pd;
            this.prepos = prepos;
            this.a = a;
            this.p = p;
            this.server = new DatagramSocket(port);
            new Thread(this, "VlaknoPrijimaci").start();
        } catch (SocketException ex) {
            Logger.getLogger(VlaknoPrijimaci.class.getName()).log(Level.SEVERE, null, ex);
        }
    }
    public DatagramSocket getSocket()
    {
        return this.server;
    }
    @Override
    public void run ()
    {    
        try 
        {            
            while(true)
            {
 
             DatagramPacket prijatyPaket = new DatagramPacket(prijata,prijata.length);
             server.receive(prijatyPaket);
 
             String prijaty = new String(prijatyPaket.getData(),0,prijatyPaket.getLength());
             System.out.println("Od  klienta:"+prijaty);              
 
 
 
             if (prijaty.equals("add"))
             {
                getPort = prijatyPaket.getPort();            
                p.setData(getPort);               
 
 
                getAddress = prijatyPaket.getAddress();
                a.setData(getAddress);                                
             }
             else 
             {  
 
                odeslana = prijaty.getBytes();
                prepos.setData(odeslana); 
                pd.setData(prijatyPaket);
 
             }
 
            }            
        } 
        catch (IOException ex) 
        {
            Logger.getLogger(VlaknoPrijimaci.class.getName()).log(Level.SEVERE, null, ex);
        }    
    }
}
 
 
class VlaknoPreposilaci implements Runnable
{
 private Preposilani prepos;
 private InetAddress klient;
 private int port;
 private DatagramSocket server;
 private Port p;
 private Adresa a;
 private int olo=0;
 private PreposilaniData pd;
 private int getPort;
 private InetAddress getAddress;
 
 private Integer port1;
 private Integer port2;
 
 private InetAddress adresa1;
 private InetAddress adresa2;
 
 private boolean bool = true;
 
 Thread preposilaci;
 VlaknoPreposilaci(Port p,Adresa a,Preposilani prepos,DatagramSocket pomA,PreposilaniData pd)
 {
            this.pd = pd;
            this.prepos = prepos;
            this.p = p;
            this.a = a;
            this.server = pomA;         
            new Thread(this, "VlaknoPreposilaci").start();       
 }
 
    @Override
 public void run()
 {  
        try {
            //Thread.sleep(10000);
            System.out.println(p.getData().get(0));
            System.out.println(a.getData().get(0));
 
            System.out.println(p.getData().get(1));
            System.out.println(a.getData().get(1));
 
            port1 = (Integer) p.getData().get(0);
            port2 = (Integer) p.getData().get(1);
 
            adresa1 = (InetAddress) a.getData().get(0);
            adresa2 = (InetAddress) a.getData().get(1);
 
          //  while(true){
 
            getPort = pd.getData().getPort();
            getAddress = pd.getData().getAddress();
 
                if (port1 == getPort) {
                    DatagramPacket odeslat1 = new DatagramPacket(prepos.getData(),prepos.getData().length,adresa1,port1);
                    server.send(odeslat1);
                    System.out.println("port1");
                } else if (port2 == getPort) {
                    DatagramPacket odeslat2 = new DatagramPacket(prepos.getData(),prepos.getData().length,adresa2,port2);
                    server.send(odeslat2);
                    System.out.println("port2");
                }
 
 
           // }
        } catch (IOException ex) {
            Logger.getLogger(VlaknoPreposilaci.class.getName()).log(Level.SEVERE, null, ex);
        }// catch (InterruptedException ex) {
          //  Logger.getLogger(VlaknoPreposilaci.class.getName()).log(Level.SEVERE, null, ex);
       // }
 
 
 }
 
}
 
 
class Port {
    List<Integer> listPort = Collections.synchronizedList(new ArrayList<Integer>(2)); 
 
    public synchronized void setData(int portt){
        listPort.add(portt);                                                     
    }
 
    public synchronized List getData(){        
      return this.listPort; 
    }
}
class Adresa {       
    private List<InetAddress> listAddress = Collections.synchronizedList(new ArrayList<InetAddress>(2));
    public synchronized void setData(InetAddress adresa){
            listAddress.add(adresa);
        }
 
    public synchronized List getData(){
        return this.listAddress;
    }
}
 
class Preposilani {
    private boolean obsazeno=false;
    byte[] odeslat = new byte[256];
    private int i;
    public synchronized void setData(byte odeslat[]){
        this.odeslat=odeslat;        
    }
 
    public synchronized byte[] getData(){
       return this.odeslat;
    }
}
 
class PreposilaniData {
    private byte[] odeslat = new byte[256];
 
    private DatagramPacket preposilanyPacket = new DatagramPacket(odeslat,odeslat.length);
    public synchronized void setData(DatagramPacket kOdeslani){
       this.preposilanyPacket=kOdeslani;        
    }
 
    public synchronized DatagramPacket getData(){
       return this.preposilanyPacket;
    }
}
 
class Shromazdovac
{
 
}

Thanks a lot for your answer.

[leandro]

Did you get an exception? Can you give us something more specific?

[Koren3]

Never mind. I will solve another way. But thank for your interest.