面试必问：Java多线程编程实例

原创秒速五厘米 2025-03-21 07:30 45阅读 0赞

在面试中，可能会被要求提供Java多线程编程的实例。以下是一个常见的例子，展示了如何使用Java创建和管理线程。

示例代码（一个简单的HTTP服务器，使用线程来处理客户端请求）：

```java
import java.io.*;
import java.net.ServerSocket;
import java.util.concurrent.ExecutorService;

public class MultiThreadedServer {
    private static final int PORT = 8000;
    private ExecutorService executor;

public MultiThreadedServer() {
        executor = Executors.newFixedThreadPool(10); // 创建线程池，限制最大并发线程数
    }

public void startServer() throws IOException {
        ServerSocket server = new ServerSocket(PORT); // 创建服务器socket，监听指定端口

System.out.println("MultiThreaded HTTP Server is running on port " + PORT);

while (true) { // 循环接收客户端请求
            executor.execute(new ThreadHandler(server.accept()))); // 每接一个客户端连接，就创建一个新的线程处理这个连接
        }
    }

// 线程处理类
    private static class ThreadHandler implements Runnable {
        private final Socket socket; // 客户端连接

public ThreadHandler(Socket socket) {
            this.socket = socket;
        }

@Override
        public void run() {
            try (BufferedReader br = new BufferedReader(new InputStreamReader(socket.getInputStream())))) { // 读取客户端发送的数据
                String request = br.readLine(); // 假设请求为GET /index.html

System.out.println("Received request: " + request);

// 处理请求（这里假设返回一个HTML响应）
                String response = "<html><body>Index Page!</body></html>";
                BufferedWriter responseWriter = new BufferedWriter(new OutputStreamWriter(socket.getOutputStream()))); // 写入客户端需要的数据
                responseWriter.write(response);
                responseWriter.flush();
            } catch (IOException e) {
                System.out.println("Error occurred while handling request: " + e.getMessage());
            } finally {
                try {
                    socket.close(); // 关闭客户端连接
                } catch (IOException ex) {
                    System.out.println("Failed to close client connection: " + ex.getMessage());
                }
            }
        }
    }

public static void main(String[] args) throws IOException {
        MultiThreadedServer server = new MultiThreadedServer();
        server.startServer(); // 启动服务器
    }
}
```

这个例子创建了一个HTTP服务器，使用Java的多线程来处理并发客户端请求。每当有新的客户端连接时，就会创建一个新的线程来处理这个连接。