Thread problem

Question

neutralfox -4 Junior Poster

15 Years Ago

Hello everyone,
Actually I want to learn more about thread, can we have more than one "run" for thread in a program ?

package ignisftpv20;

import javax.swing.JFileChooser;
import java.io.*;
import java.net.*;
import javax.swing.JOptionPane;

public class FTPClient extends javax.swing.JFrame implements Runnable {




    
JFileChooser fileChooser = new JFileChooser();
File fileUpload;
ObjectInputStream input;
ObjectOutputStream output;



    FileInputStream fis;
    FileOutputStream fout;

    File file;







    public FTPClient() {
        initComponents();
        new Thread( this ).start();
    }









    @SuppressWarnings("unchecked")
    // <editor-fold defaultstate="collapsed" desc="Generated Code">
    private void initComponents() {

        btnBrowse = new javax.swing.JButton();
        btnSend = new javax.swing.JButton();
        btnConnect = new javax.swing.JButton();

        setDefaultCloseOperation(javax.swing.WindowConstants.EXIT_ON_CLOSE);
        setTitle("FTP Client");

        btnBrowse.setText("Browse");
        btnBrowse.addActionListener(new java.awt.event.ActionListener() {
            public void actionPerformed(java.awt.event.ActionEvent evt) {
                btnBrowseActionPerformed(evt);
            }
        });

        btnSend.setText("Send File");
        btnSend.addActionListener(new java.awt.event.ActionListener() {
            public void actionPerformed(java.awt.event.ActionEvent evt) {
                btnSendActionPerformed(evt);
            }
        });

        btnConnect.setText("Connect");
        btnConnect.addActionListener(new java.awt.event.ActionListener() {
            public void actionPerformed(java.awt.event.ActionEvent evt) {
                btnConnectActionPerformed(evt);
            }
        });

        javax.swing.GroupLayout layout = new javax.swing.GroupLayout(getContentPane());
        getContentPane().setLayout(layout);
        layout.setHorizontalGroup(
            layout.createParallelGroup(javax.swing.GroupLayout.Alignment.LEADING)
            .addGroup(layout.createSequentialGroup()
                .addGap(91, 91, 91)
                .addGroup(layout.createParallelGroup(javax.swing.GroupLayout.Alignment.LEADING)
                    .addComponent(btnSend)
                    .addComponent(btnBrowse)
                    .addComponent(btnConnect))
                .addContainerGap(107, Short.MAX_VALUE))
        );

        layout.linkSize(javax.swing.SwingConstants.HORIZONTAL, new java.awt.Component[] {btnBrowse, btnConnect, btnSend});

        layout.setVerticalGroup(
            layout.createParallelGroup(javax.swing.GroupLayout.Alignment.LEADING)
            .addGroup(layout.createSequentialGroup()
                .addGap(65, 65, 65)
                .addComponent(btnConnect)
                .addPreferredGap(javax.swing.LayoutStyle.ComponentPlacement.UNRELATED)
                .addComponent(btnBrowse)
                .addPreferredGap(javax.swing.LayoutStyle.ComponentPlacement.RELATED)
                .addComponent(btnSend, javax.swing.GroupLayout.PREFERRED_SIZE, 35, javax.swing.GroupLayout.PREFERRED_SIZE)
                .addContainerGap(113, Short.MAX_VALUE))
        );

        layout.linkSize(javax.swing.SwingConstants.VERTICAL, new java.awt.Component[] {btnBrowse, btnConnect, btnSend});

        java.awt.Dimension screenSize = java.awt.Toolkit.getDefaultToolkit().getScreenSize();
        setBounds((screenSize.width-281)/2, (screenSize.height-327)/2, 281, 327);
    }// </editor-fold>











//browse
    private void btnBrowseActionPerformed(java.awt.event.ActionEvent evt) {
        int flag = fileChooser.showOpenDialog(FTPClient.this);

        if (flag == JFileChooser.APPROVE_OPTION) {
            fileUpload = fileChooser.getSelectedFile();

        }



}



//connect
    private void btnConnectActionPerformed(java.awt.event.ActionEvent evt) {
       try{

            Socket s = new Socket ("127.0.0.1" , 5555);
            input = new ObjectInputStream(s.getInputStream());
            output = new ObjectOutputStream(s.getOutputStream());
            JOptionPane.showMessageDialog(null, "OK Houston");
            }catch(Exception e){e.printStackTrace();}


    }

    
    
//send file
    private void btnSendActionPerformed(java.awt.event.ActionEvent evt) {

           new Thread(this).start();
    }


    public static void main(String args[]) {
        java.awt.EventQueue.invokeLater(new Runnable() {
            public void run() {
                new FTPClient().setVisible(true);
            }
        });
    }

public void run(){

        sendBytes();

}


public void sendBytes(){
        try{
            fis = new FileInputStream(fileUpload.getName());


            byte[] buffer = new byte[1024];
            int bytes = 0;

            while((bytes = fis.read(buffer))!=-1)
            {
                output.write(buffer,0,bytes);

            }




        }catch(Exception e){e.printStackTrace();}

}
    

    // Variables declaration - do not modify
    private javax.swing.JButton btnBrowse;
    private javax.swing.JButton btnConnect;
    private javax.swing.JButton btnSend;
    // End of variables declaration

}

I want to run everything in button Connect, btnConnect

//connect
private void btnConnectActionPerformed
.
.
.

in a new thread.

How to do that, thanks.

java

4 Contributors
26 Replies
256 Views
3 Days Discussion Span
Latest Post 15 Years Ago Latest Post by BestJewSinceJC

JamesCherrill 4,733 Most Valuable Poster

15 Years Ago

Not certain that I understand the Q, but you can only have 1 run() in a class, so if there are other things you want to start new threads for you need an additional small Runnable class to do it. You can use an anonymous inner class (Google it if unfamiliar) for this, like this:

new Thread(new Runnable() {
  public void run() {
      // call a method in your main class to do the work 
  }
}).start();

JamesCherrill 4,733 Most Valuable Poster

15 Years Ago

You start the server on the Swing event thread, and in that you wait for the connection, thus blocking the Swing thread.

BestJewSinceJC 700 Posting Maven

15 Years Ago

When you have GUI applications, they usually should run on the Event Dispatch Thread. The EDT is what James is talking about when he says the Swing thread. Since you are waiting for a connection on the EDT, you are blocking the thread, since a Thread can only do one task at once. (Think of it like this: when you run any old program, the code executes in order, so the later code has to wait for the earlier code to execute). If you read the first page of the link, you'll gain a better understanding of the event dispatch thread. Also, there is a link in there on the first page to "memory consistency errors". I personally think it is interesting, you may want to check that out also, although it is slightly off topic.

JamesCherrill 4,733 Most Valuable Poster

15 Years Ago

Without an up-to-date code listing there's not a lot I can do, but...
Maybe you should take a few moments to clarify your architecture in terms of its threading. You need 3+ threads, (1) The "swing" or "EDT" thread where you do all your user interface stuff. (2) The server thread where you wait for new connections and (3) the connection handler thread(s) that you create to handle each connection as it's made.
So in your main(...) method I would expect to see a call to set up the GUI (which if you want to be pedantic you should schedule on the Swing thread, but few people would bother), and a new Thread to start the server. Judging by the code you posted, I suspect you may be getting problems because you have mixed the server code in with the GUI code - they really should be separate.

JamesCherrill 4,733 Most Valuable Poster

15 Years Ago

Don't have time to read all code now, but it looks like you're still starting the server in the Swing thread!

Reply to this topic

Be a part of the DaniWeb community

We're a friendly, industry-focused community of developers, IT pros, digital marketers, and technology enthusiasts meeting, networking, learning, and sharing knowledge.

neutralfox -4 Junior Poster · Answer 1 · 2009-04-13T21:49:34+00:00

Hello,
Thanks for the answer. I am having another problem. My application freeze. I have done a similar application, chat and it was working, now i applied the same logic for the ftp and its freezing. Can someone help me please.

neutralfox -4 Junior Poster · Answer 2 · 2009-04-13T21:56:39+00:00

This is the server class:

package ignisftpv20;

import java.net.*;
import java.io.*;
import javax.swing.JOptionPane;


public class FTPServer extends javax.swing.JFrame implements Runnable {





    public FTPServer() {
        initComponents();
    }



    @SuppressWarnings("unchecked")
    // <editor-fold defaultstate="collapsed" desc="Generated Code">
    private void initComponents() {

        btnServer = new javax.swing.JButton();

        setDefaultCloseOperation(javax.swing.WindowConstants.EXIT_ON_CLOSE);
        setTitle("FTP Server");

        btnServer.setText("Start Server");
        btnServer.addActionListener(new java.awt.event.ActionListener() {
            public void actionPerformed(java.awt.event.ActionEvent evt) {
                btnServerActionPerformed(evt);
            }
        });

        javax.swing.GroupLayout layout = new javax.swing.GroupLayout(getContentPane());
        getContentPane().setLayout(layout);
        layout.setHorizontalGroup(
            layout.createParallelGroup(javax.swing.GroupLayout.Alignment.LEADING)
            .addGroup(layout.createSequentialGroup()
                .addGap(78, 78, 78)
                .addComponent(btnServer)
                .addContainerGap(96, Short.MAX_VALUE))
        );
        layout.setVerticalGroup(
            layout.createParallelGroup(javax.swing.GroupLayout.Alignment.LEADING)
            .addGroup(javax.swing.GroupLayout.Alignment.TRAILING, layout.createSequentialGroup()
                .addContainerGap(52, Short.MAX_VALUE)
                .addComponent(btnServer, javax.swing.GroupLayout.PREFERRED_SIZE, 33, javax.swing.GroupLayout.PREFERRED_SIZE)
                .addGap(38, 38, 38))
        );

        pack();
    }// </editor-fold>






    private void btnServerActionPerformed(java.awt.event.ActionEvent evt) {
       
        new Thread (this).start();

    }



    public void run(){

        waitForConnection();
    }



public void waitForConnection(){
            try{
                ServerSocket ss = new ServerSocket(5555);

                    while(true){
                        Socket soc = ss.accept();
                        JOptionPane.showMessageDialog(null, "I got a connection!");
                        System.out.println("Connected from: "+ soc.getInetAddress().getHostName()+"..." );

                        new FTPServerReceiver( this, soc );
                         new Thread (this).start();

                    }
            
            }catch(Exception e){ e.printStackTrace();}

}




    public static void main(String args[]) {
        java.awt.EventQueue.invokeLater(new Runnable() {
            public void run() {
                new FTPServer().setVisible(true);
            }
        });
    }

    // Variables declaration - do not modify
    private javax.swing.JButton btnServer;
    // End of variables declaration

}

neutralfox -4 Junior Poster · Answer 3 · 2009-04-13T22:06:13+00:00

Yes,in the waitForConnection, it was a mistake.

But " start the server on the Swing event thread", you mean on the button?

neutralfox -4 Junior Poster · Answer 4 · 2009-04-14T20:26:06+00:00

Hello ... thanks for the answer, i read it but still can't solve the problem, its not working when I removed the tread from the constructor.

The message "OK Houston" does not appears which means that the blocking situation is over there.

Thanks in advance.

neutralfox -4 Junior Poster · Answer 5 · 2009-04-14T21:25:58+00:00

Hello,
I am sending you the modified one, please put a comment for me to understand this.

Thanks in advance.

package ignisftpv20;

import javax.swing.JFileChooser;
import java.io.*;
import java.net.*;
import javax.swing.JOptionPane;

public class FTPClient extends javax.swing.JFrame implements Runnable {




    
JFileChooser fileChooser = new JFileChooser();
File fileUpload;
ObjectInputStream input;
ObjectOutputStream output;



    FileInputStream fis;
    FileOutputStream fout;

    File file;







    public FTPClient() {
        initComponents();
       
     


    }









    @SuppressWarnings("unchecked")
    // <editor-fold defaultstate="collapsed" desc="Generated Code">                          
    private void initComponents() {

        btnBrowse = new javax.swing.JButton();
        btnSend = new javax.swing.JButton();
        btnConnect = new javax.swing.JButton();

        setDefaultCloseOperation(javax.swing.WindowConstants.EXIT_ON_CLOSE);
        setTitle("FTP Client");

        btnBrowse.setText("Browse");
        btnBrowse.addActionListener(new java.awt.event.ActionListener() {
            public void actionPerformed(java.awt.event.ActionEvent evt) {
                btnBrowseActionPerformed(evt);
            }
        });

        btnSend.setText("Send File");
        btnSend.addActionListener(new java.awt.event.ActionListener() {
            public void actionPerformed(java.awt.event.ActionEvent evt) {
                btnSendActionPerformed(evt);
            }
        });

        btnConnect.setText("Connect");
        btnConnect.addActionListener(new java.awt.event.ActionListener() {
            public void actionPerformed(java.awt.event.ActionEvent evt) {
                btnConnectActionPerformed(evt);
            }
        });

        javax.swing.GroupLayout layout = new javax.swing.GroupLayout(getContentPane());
        getContentPane().setLayout(layout);
        layout.setHorizontalGroup(
            layout.createParallelGroup(javax.swing.GroupLayout.Alignment.LEADING)
            .addGroup(layout.createSequentialGroup()
                .addGap(91, 91, 91)
                .addGroup(layout.createParallelGroup(javax.swing.GroupLayout.Alignment.LEADING)
                    .addComponent(btnSend)
                    .addComponent(btnBrowse)
                    .addComponent(btnConnect))
                .addContainerGap(107, Short.MAX_VALUE))
        );

        layout.linkSize(javax.swing.SwingConstants.HORIZONTAL, new java.awt.Component[] {btnBrowse, btnConnect, btnSend});

        layout.setVerticalGroup(
            layout.createParallelGroup(javax.swing.GroupLayout.Alignment.LEADING)
            .addGroup(layout.createSequentialGroup()
                .addGap(65, 65, 65)
                .addComponent(btnConnect)
                .addPreferredGap(javax.swing.LayoutStyle.ComponentPlacement.UNRELATED)
                .addComponent(btnBrowse)
                .addPreferredGap(javax.swing.LayoutStyle.ComponentPlacement.RELATED)
                .addComponent(btnSend, javax.swing.GroupLayout.PREFERRED_SIZE, 35, javax.swing.GroupLayout.PREFERRED_SIZE)
                .addContainerGap(113, Short.MAX_VALUE))
        );

        layout.linkSize(javax.swing.SwingConstants.VERTICAL, new java.awt.Component[] {btnBrowse, btnConnect, btnSend});

        java.awt.Dimension screenSize = java.awt.Toolkit.getDefaultToolkit().getScreenSize();
        setBounds((screenSize.width-281)/2, (screenSize.height-327)/2, 281, 327);
    }// </editor-fold>                        











//browse
    private void btnBrowseActionPerformed(java.awt.event.ActionEvent evt) {                                          
        int flag = fileChooser.showOpenDialog(FTPClient.this);

        if (flag == JFileChooser.APPROVE_OPTION) {
            fileUpload = fileChooser.getSelectedFile();

        }



}                                         



//connect
    private void btnConnectActionPerformed(java.awt.event.ActionEvent evt) {                                           

        connectToServer();


    }                                          


    
    
//send file
    private void btnSendActionPerformed(java.awt.event.ActionEvent evt) {                                        

           new Thread(this).start();
    }                                       


    public static void main(String args[]) {
        java.awt.EventQueue.invokeLater(new Runnable() {
            public void run() {
                new FTPClient().setVisible(true);
            }
        });
    }


public void run(){
        connectToServer();
        sendBytes();

}


public void connectToServer(){

           try{
                Socket s = new Socket ("127.0.0.1" , 5555);
                input = new ObjectInputStream(s.getInputStream());
                output = new ObjectOutputStream(s.getOutputStream());
                JOptionPane.showMessageDialog(null, "OK Houston");
            }catch(Exception e){e.printStackTrace();}
}





public void sendBytes(){
        try{
            fis = new FileInputStream(fileUpload.getName());


            byte[] buffer = new byte[1024];
            int bytes = 0;

            while((bytes = fis.read(buffer))!=-1)
            {
                output.write(buffer,0,bytes);

            }




        }catch(Exception e){e.printStackTrace();}

}
    

    // Variables declaration - do not modify                     
    private javax.swing.JButton btnBrowse;
    private javax.swing.JButton btnConnect;
    private javax.swing.JButton btnSend;
    // End of variables declaration                   

}

package ignisftpv20;

import java.net.*;
import java.io.*;
import javax.swing.JOptionPane;


public class FTPServer extends javax.swing.JFrame implements Runnable {





    public FTPServer() {
        initComponents();
        new Thread (this).start();
    }



    @SuppressWarnings("unchecked")
    // <editor-fold defaultstate="collapsed" desc="Generated Code">                          
    private void initComponents() {

        btnServer = new javax.swing.JButton();

        setDefaultCloseOperation(javax.swing.WindowConstants.EXIT_ON_CLOSE);
        setTitle("FTP Server");

        btnServer.setText("Start Server");
        btnServer.addActionListener(new java.awt.event.ActionListener() {
            public void actionPerformed(java.awt.event.ActionEvent evt) {
                btnServerActionPerformed(evt);
            }
        });

        javax.swing.GroupLayout layout = new javax.swing.GroupLayout(getContentPane());
        getContentPane().setLayout(layout);
        layout.setHorizontalGroup(
            layout.createParallelGroup(javax.swing.GroupLayout.Alignment.LEADING)
            .addGroup(layout.createSequentialGroup()
                .addGap(78, 78, 78)
                .addComponent(btnServer)
                .addContainerGap(96, Short.MAX_VALUE))
        );
        layout.setVerticalGroup(
            layout.createParallelGroup(javax.swing.GroupLayout.Alignment.LEADING)
            .addGroup(javax.swing.GroupLayout.Alignment.TRAILING, layout.createSequentialGroup()
                .addContainerGap(52, Short.MAX_VALUE)
                .addComponent(btnServer, javax.swing.GroupLayout.PREFERRED_SIZE, 33, javax.swing.GroupLayout.PREFERRED_SIZE)
                .addGap(38, 38, 38))
        );

        pack();
    }// </editor-fold>                        






    private void btnServerActionPerformed(java.awt.event.ActionEvent evt) {                                          
       
        

    }                                         



    public void run(){

        waitForConnection();
    }



public void waitForConnection(){
            try{
                ServerSocket ss = new ServerSocket(5555);

                    while(true){
                        Socket soc = ss.accept();
                        JOptionPane.showMessageDialog(null, "I got a connection!");
                        System.out.println("Connected from: "+ soc.getInetAddress().getHostName()+"..." );

                        new FTPServerReceiver( this, soc );
                      

                    }
            
            }catch(Exception e){ e.printStackTrace();}

}




    public static void main(String args[]) {
        java.awt.EventQueue.invokeLater(new Runnable() {
            public void run() {
                new FTPServer().setVisible(true);
            }
        });
    }

    // Variables declaration - do not modify                     
    private javax.swing.JButton btnServer;
    // End of variables declaration                   

}



[code]



package ignisftpv20;

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

public class FTPServerReceiver implements Runnable{


    FTPServer ftpServer;
    Socket thesocket;
    Byte bt;
    ObjectInputStream input;
    FileOutputStream fout;

    String directoryName = "C:/Documents and Settings/Host Intruder/Desktop/Complete Download";




    public FTPServerReceiver(FTPServer ftpServer, Socket s){

        this.ftpServer = ftpServer;
        this.thesocket = s;
        new Thread( this ).start();
    }

//read and write file
    public void run(){

        try{
            while(true){


            input = new ObjectInputStream(thesocket.getInputStream());
            byte[] buffer = new byte[1024];
            int bytes = 0;
            
            //input.read(buffer,0,bytes);

            File f = new File(directoryName,"file1");
            fout = new FileOutputStream(f);


            fout.write(input.read(buffer,0,bytes));







            }

        }catch(Exception e){e.printStackTrace();}



    }
}

[/code]

neutralfox -4 Junior Poster · Answer 6 · 2009-04-14T22:02:27+00:00

Thanks for the answer but where James. You mean here:

public FTPServer() {
        initComponents();
        new Thread (this).start();
    }

should be like this:

public FTPServer() {
        initComponents();
        //remove
    }

I have tried but its still not working.

JamesCherrill 4,733 Most Valuable Poster Team Colleague Featured Poster · Answer 7 · 2009-04-14T22:44:51+00:00

(sorry man, need to go offline now, will get back tomorrow with any luck)

neutralfox -4 Junior Poster · Answer 8 · 2009-04-14T22:46:29+00:00

neutralfox -4 Junior Poster

15 Years Ago

Its OK ... thanks.

aleb 0 Newbie Poster · Answer 9 · 2009-04-15T08:15:42+00:00

aleb 0 Newbie Poster

15 Years Ago

fyi
www.searchjava.org

neutralfox -4 Junior Poster · Answer 10 · 2009-04-15T21:24:13+00:00

Thanks for the info, but my problem is still unsolved.. can't get it to work.

JamesCherrill 4,733 Most Valuable Poster Team Colleague Featured Poster · Answer 11 · 2009-04-15T21:43:20+00:00

I can't add much to what I said in post 9. I would separate the GUI, the server, and the connection handler into 3 classes, and make sure each is started in its own thread. This really looks like the code "just grew" to the point where it's too hard to work with, you have to go back and do a bit of design!

BestJewSinceJC 700 Posting Maven · Answer 12 · 2009-04-15T21:56:22+00:00

BestJewSinceJC 700 Posting Maven

15 Years Ago

Model View Controller

. . .

neutralfox -4 Junior Poster · Answer 13 · 2009-04-15T22:44:09+00:00

Okie .. thanks for the answers James, I will work it out and let you know if I am having any problems, thanks for the info BJSJC. ;)

neutralfox -4 Junior Poster · Answer 14 · 2009-04-16T01:49:56+00:00

Thanks a lot James, I followed your instructions and its working fine. I've just separated the user interface from the business logic. But still can't understand the logic, I will not mark this thread as solve yet as I got some questions.

Thanks a lot.

JamesCherrill 4,733 Most Valuable Poster Team Colleague Featured Poster · Answer 15 · 2009-04-16T01:59:28+00:00

OK neutralfox, stick with it! (ps what time zone are you in, if you don't mind saying?)

BestJewSinceJC 700 Posting Maven · Answer 16 · 2009-04-16T13:46:12+00:00

Okie .. thanks for the answers James, I will work it out and let you know if I am having any problems, thanks for the info BJSJC. ;)

You're welcome, but I don't know how much you got out of that (unless you went on to read other articles on the topic), because I'm finding myself feeling like I know less and less about the topic as I read more. I'll be back to ask questions about it on this forum though (not the definition of mvc, but the application of it), so maybe we can all learn something.

:)

neutralfox -4 Junior Poster · Answer 17 · 2009-04-16T13:51:42+00:00

Yeppp, we never stop to learn. Thanks a lot for all your help ... GMT+4 and you.

BestJewSinceJC 700 Posting Maven · Answer 18 · 2009-04-16T14:06:03+00:00

BestJewSinceJC 700 Posting Maven

15 Years Ago

GMT-5

JamesCherrill 4,733 Most Valuable Poster Team Colleague Featured Poster · Answer 19 · 2009-04-16T14:30:14+00:00

GMT+2 (including summer time). I'm certainly up for discussions on design patterns. I've spent many years teaching and consulting on OO design with companies such as IBM and HP, so it's a real passion of mine.
For starters, let me suggest that MVC in Swing really doesn't fit. It's painful to try to separate the view from the controller in a typical Swing UI. In practice it almost always compacts down to a UI / Business Objects(s) 2-layer model. You only need full MVC where there are many business objects and you need some kind of overall "process control" to marshal them.
Or maybe we should take this to a new thread?
J

JamesCherrill 4,733 Most Valuable Poster Team Colleague Featured Poster · Answer 20 · 2009-04-16T14:30:44+00:00

JamesCherrill 4,733 Most Valuable Poster

15 Years Ago

GMT-5

Wow, you get up early!

BestJewSinceJC 700 Posting Maven · Answer 21 · 2009-04-16T15:06:24+00:00

It's painful to try to separate the view from the controller in a typical Swing UI. In practice it almost always compacts down to a UI / Business Objects(s) 2-layer model.
J

It seems to be practically the same thing with three tiered architecture. At least for small applications.