|
73 | 73 | import java.io.InputStream; |
74 | 74 | import java.io.OutputStream; |
75 | 75 | import java.net.URI; |
| 76 | +import java.util.Collections; |
76 | 77 | import java.util.HashMap; |
77 | 78 | import java.util.Iterator; |
78 | 79 | import java.util.LinkedList; |
@@ -217,7 +218,7 @@ public AsyncHttpClient(SchemeRegistry schemeRegistry) { |
217 | 218 | ThreadSafeClientConnManager cm = new ThreadSafeClientConnManager(httpParams, schemeRegistry); |
218 | 219 |
|
219 | 220 | threadPool = getDefaultThreadPool(); |
220 | | - requestMap = new WeakHashMap<Context, List<RequestHandle>>(); |
| 221 | + requestMap = Collections.synchronizedMap(new WeakHashMap<Context, List<RequestHandle>>()); |
221 | 222 | clientHeaderMap = new HashMap<String, String>(); |
222 | 223 |
|
223 | 224 | httpContext = new SyncBasicHttpContext(new BasicHttpContext()); |
@@ -1084,7 +1085,7 @@ protected RequestHandle sendRequest(DefaultHttpClient client, HttpContext httpCo |
1084 | 1085 | // Add request to request map |
1085 | 1086 | List<RequestHandle> requestList = requestMap.get(context); |
1086 | 1087 | if (requestList == null) { |
1087 | | - requestList = new LinkedList(); |
| 1088 | + requestList = new LinkedList<RequestHandle>(); |
1088 | 1089 | requestMap.put(context, requestList); |
1089 | 1090 | } |
1090 | 1091 |
|
@@ -1125,7 +1126,7 @@ public void setURLEncodingEnabled(boolean enabled) { |
1125 | 1126 | public static String getUrlWithQueryString(boolean shouldEncodeUrl, String url, RequestParams params) { |
1126 | 1127 | if (url == null) |
1127 | 1128 | return null; |
1128 | | - |
| 1129 | + |
1129 | 1130 | if (shouldEncodeUrl) |
1130 | 1131 | url = url.replace(" ", "%20"); |
1131 | 1132 |
|
|
0 commit comments