CPP-2378 minor refactoring

This commit is contained in:
Vyacheslav Karpukhin
2015-02-25 13:31:14 +01:00
parent 026b0d97c3
commit 87d1453409
@@ -30,6 +30,7 @@ import java.util.concurrent.Future;
* @author traff
*/
public abstract class BaseOutputReader extends BaseDataReader {
protected static final int DELAY_AFTER_BLOCKING_READ = 10;
protected final Reader myReader;
@@ -63,7 +64,7 @@ public abstract class BaseOutputReader extends BaseDataReader {
@Override
public void run() {
try {
Thread.sleep(10);
Thread.sleep(DELAY_AFTER_BLOCKING_READ);
submitToken();
}
catch (InterruptedException ignore) { }