Renamed Aborter to WaitingThreadAborter
git-svn-id: https://svn.apache.org/repos/asf/httpcomponents/httpclient/trunk@649220 13f79535-47bb-0310-9956-ffa450edef68
This commit is contained in:
parent
d3205ff522
commit
ef548b4620
|
@ -221,7 +221,7 @@ public class ConnPoolByRoute extends AbstractConnPool {
|
||||||
final HttpRoute route,
|
final HttpRoute route,
|
||||||
final Object state) {
|
final Object state) {
|
||||||
|
|
||||||
final Aborter aborter = new Aborter();
|
final WaitingThreadAborter aborter = new WaitingThreadAborter();
|
||||||
|
|
||||||
return new PoolEntryRequest() {
|
return new PoolEntryRequest() {
|
||||||
|
|
||||||
|
@ -246,7 +246,7 @@ public class ConnPoolByRoute extends AbstractConnPool {
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* Obtains a pool entry with a connection within the given timeout.
|
* Obtains a pool entry with a connection within the given timeout.
|
||||||
* If a {@link WaitingThread} is used to block, {@link Aborter#setWaitingThread(WaitingThread)}
|
* If a {@link WaitingThread} is used to block, {@link WaitingThreadAborter#setWaitingThread(WaitingThread)}
|
||||||
* must be called before blocking, to allow the thread to be interrupted.
|
* must be called before blocking, to allow the thread to be interrupted.
|
||||||
*
|
*
|
||||||
* @param route the route for which to get the connection
|
* @param route the route for which to get the connection
|
||||||
|
@ -267,7 +267,7 @@ public class ConnPoolByRoute extends AbstractConnPool {
|
||||||
protected BasicPoolEntry getEntryBlocking(
|
protected BasicPoolEntry getEntryBlocking(
|
||||||
HttpRoute route, Object state,
|
HttpRoute route, Object state,
|
||||||
long timeout, TimeUnit tunit,
|
long timeout, TimeUnit tunit,
|
||||||
Aborter aborter)
|
WaitingThreadAborter aborter)
|
||||||
throws ConnectionPoolTimeoutException, InterruptedException {
|
throws ConnectionPoolTimeoutException, InterruptedException {
|
||||||
|
|
||||||
Date deadline = null;
|
Date deadline = null;
|
||||||
|
|
|
@ -1,7 +1,7 @@
|
||||||
/*
|
/*
|
||||||
* $HeadURL:$
|
* $HeadURL$
|
||||||
* $Revision:$
|
* $Revision$
|
||||||
* $Date:$
|
* $Date$
|
||||||
*
|
*
|
||||||
* ====================================================================
|
* ====================================================================
|
||||||
*
|
*
|
||||||
|
@ -31,7 +31,7 @@
|
||||||
package org.apache.http.impl.conn.tsccm;
|
package org.apache.http.impl.conn.tsccm;
|
||||||
|
|
||||||
/** A simple class that can interrupt a {@link WaitingThread}. */
|
/** A simple class that can interrupt a {@link WaitingThread}. */
|
||||||
public class Aborter {
|
public class WaitingThreadAborter {
|
||||||
|
|
||||||
private WaitingThread waitingThread;
|
private WaitingThread waitingThread;
|
||||||
private boolean aborted;
|
private boolean aborted;
|
Loading…
Reference in New Issue