Initzialer Commit mit dem aktuellen Stand

This commit is contained in:
eichehome 2021-05-11 13:59:08 +02:00
parent ba4867d4f5
commit c50b9c4aff
14 changed files with 2291 additions and 0 deletions

View file

@ -0,0 +1,47 @@
/*
* To change this license header, choose License Headers in Project Properties.
* To change this template file, choose Tools | Templates
* and open the template in the editor.
*/
package server;
import java.net.Socket;
/**
*
* @author eichehome
*/
public class ClientMessageDistributorThread implements Runnable {
/**
* Verzeichniss der Threads, die die Clients überwachen
*/
private Socket[] clientThreads = null;
/**
* Puffer der Nachrichten
*/
private Object[] messages = null;
public void run() {
}
public void ClientMessageDistributorThread(Socket s) {
}
public void pushMessage(Object message) {
Object[] temp = new Object[messages.length + 1];
temp[temp.length -1] = message;
messages = temp;
}
public Object popMessage() {
Object[] temp = new Object[messages.length - 1];
Object message = messages[0];
for (int i = 1; i < messages.length; i++) {
temp[i - 1] = messages[i];
}
messages = temp;
}
}