मेरे पास जावा में एक बहु-थ्रेडेड इको सर्वर के लिए एक सरल कोड है (यह ग्राहकों को जो कुछ भी वापस प्राप्त करता है) देता है। मैं थ्रेड आंकड़ों सहित सर्वर के विभिन्न संसाधनों का प्रोफाइल कर रहा हूं। कनेक्ट किए गए ग्राहकों की संख्या के अनुसार इनमें से कुछ आंकड़े नीचे दिए गए हैं। मेरे प्रश्न बेसलाइन के लिए हैं (ग्राहकों के 0 0) गैर-बेसलाइनों की तुलना में!डेमॉन थ्रेड, थ्रेड गिनती, और कुल थ्रेड गिनती
1) जब एक ग्राहक कनेक्ट होता है, तो कुल थ्रेड गिनती 2 से बढ़ जाती है? (बाकी के लिए, यह 1)
2) दो गैर-डिमन धागे क्या हैं ?! और क्यों डिमन शुरू में 1 से बढ़ता है और फिर तय किया जाता है?
क्या वे यादृच्छिक हैं ?!
# clients 0 1 2 3 4 5 6 7 8 9 10
Total Started Thread Count 15 18 19 20 21 22 23 24 25 26 27
Thread count 14 16 17 18 19 20 21 22 23 24 25
Peak thread count 14 16 17 18 19 20 21 22 23 24 25
Daemon thread count 12 13 13 13 13 13 13 13 13 13 13
यहां सर्वर के लिए कोड का टुकड़ा है। मैं दोनों आरएमआई (ग्राहकों के लिए मतदान संदेशों के लिए) और सर्वर सॉकेट (ग्राहकों को संदेश भेजने के लिए) का उपयोग कर रहा हूं। यदि अन्य कक्षाओं की आवश्यकता है तो मुझे बताएं।
package test;
import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStreamReader;
import java.io.PrintWriter;
import java.net.ServerSocket;
import java.net.Socket;
import java.rmi.registry.LocateRegistry;
import java.rmi.registry.Registry;
import java.rmi.server.UnicastRemoteObject;
import java.util.Vector;
public class ServerRMI extends Thread implements Hello {
//centralized token manager runs polling server and socket server to receive updated tokens
static Vector<String> tokenList= new Vector<String>();
protected Socket clientSocket;
static int RMIRegistryPort=9001;
static int SocketServerPort=9010;
public static void main(String[] args) throws IOException {
try {
ServerRMI obj = new ServerRMI();
Hello stub = (Hello) UnicastRemoteObject.exportObject(obj, 0);
// Bind the remote object's stub in the registry
Registry registry = LocateRegistry.createRegistry(RMIRegistryPort);
registry.bind("Hello", stub);
System.err.println("Server ready");
} catch (Exception e) {
System.err.println("Server exception: " + e.toString());
e.printStackTrace();
}
ServerSocket serverSocket = null;
//initialize token list
//A needs to execute first
tokenList.add(0,"0");
try {
serverSocket = new ServerSocket(SocketServerPort);
System.out.println("Connection Socket Created");
try {
while (true) {
System.out.println("Waiting for Connection");
new ServerRMI(serverSocket.accept());
}
} catch (IOException e) {
System.err.println("Accept failed.");
}
} catch (IOException e) {
System.err.println("Could not listen on port: "+SocketServerPort);
} finally {
try {
serverSocket.close();
} catch (IOException e) {
System.err.println("Could not close port: "+SocketServerPort);
}
}
}
private ServerRMI(Socket clientSoc) {
clientSocket = clientSoc;
start();
}
public ServerRMI() {}{
// TODO Auto-generated constructor stub
}
public void run() {
System.out.println("New Communication Thread Started");
try {
PrintWriter out = new PrintWriter(clientSocket.getOutputStream(),
true);
BufferedReader in = new BufferedReader(new InputStreamReader(
clientSocket.getInputStream()));
String inputLine;
while ((inputLine = in.readLine()) != null) {
tokenList.add(0,inputLine);
System.out.println("Server received: " + inputLine);
// System.out.println(" ququ size: "+queue.size());
out.println(inputLine);
if (inputLine.equals("Bye."))
break;
}
out.close();
in.close();
clientSocket.close();
} catch (IOException e) {
System.err.println("Problem with Communication Server");
}
}
public String pollServer() {
if(!tokenList.isEmpty()){
String data = tokenList.get(0);
System.out.println("Poll data: "+data);
return data;
} else{
return tokenList.size()+"";
}
}
}
पोस्ट कोड है अपने को स्वीकार आप रूपरेखा उपकरण है कि आप प्रयोग कर रहे हैं में धागा जानकारी देख सकते हैं कृपया – qwwdfsad
। उदाहरण के लिए, 'jconsole' या' jvisualvm' "थ्रेड" टैब में सभी थ्रेड जानकारी दिखाता है। प्रक्रिया में कुछ प्रोफाइलर थ्रेड भी चलेंगे, जो गिनती में शामिल होंगे। –
हम आपके कोड को नहीं जानते हैं, इसलिए मुझे नहीं पता कि हम कैसे जवाब दे सकते हैं। अगर मैं आप थे, तो मैं थ्रेड डंप करता हूं जब क्लाइंट का 0 0 होता है, तो जब यह 1 होता है और उनकी तुलना करता है, तो आपको अपना उत्तर –