代码案例：package com.what21.http.client4_5;

import org.apache.http.HttpEntity;

import org.apache.http.client.methods.CloseableHttpResponse;

import org.apache.http.client.methods.HttpGet;

import org.apache.http.impl.client.CloseableHttpClient;

import org.apache.http.impl.client.HttpClients;

import org.apache.http.impl.conn.PoolingHttpClientConnectionManager;

import org.apache.http.protocol.BasicHttpContext;

import org.apache.http.protocol.HttpContext;

import org.apache.http.util.EntityUtils;

public class What21ClientMultiThreadedExecution {

public static void main(String[] args) throws Exception {

// 创建一个线程安全的连接管理

PoolingHttpClientConnectionManager cm = new PoolingHttpClientConnectionManager();

cm.setMaxTotal(100);

CloseableHttpClient httpclient = HttpClients.custom()

.setConnectionManager(cm)

.build();

try {

// 创建URL数组

String[] urisToGet = {

"http://hc.apache.org/",

"http://hc.apache.org/httpcomponents-core-ga/",

"http://www.what21.com/",

};

// 创建执行线程数组

GetThread[] threads = new GetThread[urisToGet.length];

for (int i = 0; i

HttpGet httpget = new HttpGet(urisToGet[i]);

threads[i] = new GetThread(httpclient, httpget, i + 1);

}

// 启动线程

for (int j = 0; j

threads[j].start();

}

// 线程联合(线程执行完成后，在继续往下执行)

for (int j = 0; j

threads[j].join();

}

} finally {

httpclient.close();

}

System.out.println("执行完成......");

}

// 执行线程

static class GetThread extends Thread {

private final CloseableHttpClient httpClient;

private final HttpContext context;

private final HttpGet httpget;

private final int id;

public GetThread(CloseableHttpClient httpClient, HttpGet httpget, int id) {

this.httpClient = httpClient;

this.context = new BasicHttpContext();

this.httpget = httpget;

this.id = id;

}

@Override

public void run() {

try {

System.out.println(id + " | " + httpget.getURI());

CloseableHttpResponse response = httpClient.execute(httpget, context);

try {

System.out.println(id + " | get executed");

// 响应

HttpEntity entity = response.getEntity();

if (entity != null) {

byte[] bytes = EntityUtils.toByteArray(entity);

System.out.println(id + " | " + bytes.length + " bytes read");

}

} finally {

response.close();

}

} catch (Exception e) {

System.out.println(id + " | error: " + e);

}

}

}

}

输出：2 | http://hc.apache.org/httpcomponents-core-ga/

1 | http://hc.apache.org/

3 | http://www.what21.com/

3 | get executed

3 | 46300 bytes read

1 | get executed

1 | 14283 bytes read

2 | get executed

2 | 12369 bytes read

执行完成......