|
@@ -3831,19 +3831,12 @@ public abstract class FileSystem extends Configured
|
|
|
* Background action to act on references being removed.
|
|
|
*/
|
|
|
private static class StatisticsDataReferenceCleaner implements Runnable {
|
|
|
- /**
|
|
|
- * Represents the timeout period expires for remove reference objects from
|
|
|
- * the STATS_DATA_REF_QUEUE when the queue is empty.
|
|
|
- */
|
|
|
- private static final int REF_QUEUE_POLL_TIMEOUT = 10000;
|
|
|
-
|
|
|
@Override
|
|
|
public void run() {
|
|
|
while (!Thread.interrupted()) {
|
|
|
try {
|
|
|
StatisticsDataReference ref =
|
|
|
- (StatisticsDataReference)STATS_DATA_REF_QUEUE.
|
|
|
- remove(REF_QUEUE_POLL_TIMEOUT);
|
|
|
+ (StatisticsDataReference)STATS_DATA_REF_QUEUE.remove();
|
|
|
ref.cleanUp();
|
|
|
} catch (InterruptedException ie) {
|
|
|
LOGGER.warn("Cleaner thread interrupted, will stop", ie);
|