E Kirskon

Hello all. I am relatively new to java and programming in general. It's my first post in the forum and I hope my question is not too big.

I have the code for a server/client app which is supposed to work with two users. I am aware of the basic concepts for threads, constuctors, etc, but I can seem to put it all together and understand how it works exactly.

First, in the constructor here two threads are created and started. I am not sure what exactly should the "this" should represent in this case :

thrOne = new Thread(this);

Is it the construcotr passing itself to the newly created thread? If, yes how does it work? Is there another way?
Second thing is the case with the two threads used in this Server class. I guess, that threads are two since the users are supposed to be two as well. But is it a good idea to be done like that? And how does the server assign the different threads to different users. I am lost.

Sorry again if my question is too big.
Best regards.


public class Server implements Runnable { ServerSocket serverSocket; Socket socketOne, socketTwo; BufferedReader br, br1; PrintWriter pw, pw1; Thread thrOne, thrTwo; String str; public Server(){ try { serverSocket = new ServerSocket(4444); socketOne = serverSocket.accept(); System.out.println("One client is connected"); socketTwo = serverSocket.accept(); System.out.println("Second client is connected"); br = new BufferedReader(new InputStreamReader(socketOne.getInputStream())); br1 = new BufferedReader(new InputStreamReader(socketTwo.getInputStream())); pw = new PrintWriter(socketOne.getOutputStream(), true); pw1 = new PrintWriter(socketTwo.getOutputStream(), true); thrOne = new Thread(this); thrTwo = new Thread(this); thrOne.start(); thrTwo.start(); } catch (Exception ee) { ee.printStackTrace(); } } public void run() { try { while (true) { if (Thread.currentThread() == thrOne) { str = br.readLine(); System.out.println(str + "++++++++++"); pw1.println(str); pw1.flush(); Thread.sleep(800); } else { str = br1.readLine(); System.out.println(str+"second"); pw.println(str); pw.flush(); Thread.sleep(800); } } } catch (Exception ee) { ee.printStackTrace(); } } public static void main(String arg[]) { new Server(); } }