Advertisement
Not a member of Pastebin yet?
Sign Up,
it unlocks many cool features!
- class User
- {
- private Socket mySocket;
- private Thread outputHandler;
- private ConcurrentLinkedQueue<String> outgoingText;
- //Constructor
- public User(ConcurrentLinkedQueue<Socket> incomingSockets)
- {
- //Uses the next new connection in queue to create a user
- mySocket = incomingSockets.poll();
- outputHandler = new Thread(new OutputHandler(mySocket, outgoingText));
- outputHandler.start();
- }
- //Public Methods
- public void SendText(String text)
- {
- outgoingText.add(text);
- }
- }
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement