我刚刚被多线程弄湿了，它真的很棒。我发现自己试图找出可以使用它的新方法来让事情变得更好，我想我找到了一个，但我不确定如何为此设计程序。
这是情况。我有一个队列服务器，多个客户端消费并产生数据，但是为了启动这个过程，我运行了一个 java 程序来放置一些初始数据供他们启动。然后我的程序完成了，队列服务器上有多余的容量，但实际上没有运行任何东西。所以我想尝试做一些维护任务，运行服务，做低优先级的事情。我不知道怎么做。如何设计一个同时执行完全不同任务的程序？
通常我只是将我的程序包装在一个while (true)循环中，它只执行一个任务，我意识到我不能在同一个进程中同时执行两个 while 循环（可能是嵌套的？）。为了展示一个简化的例子，我放了一堆运行可运行的代码（也许它会处理一个低优先级队列）和一个监视套接字并回复的服务（我可能想根据 cpu 使用情况添加更多）。我如何让他们一起工作？有没有更好的设计方法（我知道长期运行多个java进程可能更好，但现在我只是想管理一个文件，我怀疑有一种方法可以为套接字服务提供比处理更高的优先级在文件中排队，但如果它们都在不同的文件中运行，我不会
谢谢，如果事实证明我解释的完全错误，我会编辑这个问题。但简而言之，我希望它为其他系统（示例中的服务器套接字）提供服务，并且当它空闲时，我希望它执行一些其他任务。
示例（如果您了解我的要求，则可能不需要阅读此代码）：
import java.io.IOException;
import java.io.ObjectInputStream;
import java.io.ObjectOutputStream;
import java.net.ServerSocket;
import java.net.Socket;
public class multipleThreads {
private ServerSocket server;
private int port = 7777;
public void ServerSocketExample() {
try {
server = new ServerSocket(port);
} catch (IOException e) {
e.printStackTrace();
}
}
public static void main(String[] args) {
// TODO Auto-generated method stub
System.out.println("starting");
ServerSocketExample example = new ServerSocketExample();
example.handleConnection();
while (true) {
//monitor low low priority queue
}
}
public void handleConnection() {
System.out.println("Waiting for client message...");
//
// The server do a loop here to accept all connection initiated by the
// client application.
//
while (true) {
try {
Socket socket = server.accept();
new ConnectionHandler(socket);
} catch (IOException e) {
e.printStackTrace();
}
}
}
}
class ConnectionHandler implements Runnable {
private Socket socket;
public ConnectionHandler(Socket socket) {
this.socket = socket;
Thread t = new Thread(this);
t.start();
}
public void run() {
try
{
//
// Read a message sent by client application
//
ObjectInputStream ois = new ObjectInputStream(socket.getInputStream());
String message = (String) ois.readObject();
System.out.println("Message Received: " + message);
//
// Send a response information to the client application
//
ObjectOutputStream oos = new ObjectOutputStream(socket.getOutputStream());
oos.writeObject("Hi...");
ois.close();
oos.close();
socket.close();
System.out.println("Waiting for client message...");
} catch (IOException e) {
e.printStackTrace();
} catch (ClassNotFoundException e) {
e.printStackTrace();
}
}
}
class MonitorQueue implements Runnable{
@Override
public void run() {
// TODO Auto-generated method stub
//do work when stuff comes in the queue
}
}