У меня есть очередь запущенных потоков, и я хотел бы выставить некоторые из ее данных во время ее выполнения, чтобы отслеживать процесс.
ThreadPoolExecutor
предоставляет доступ к своей очереди, и я могу перебирать эти объекты, чтобы вызвать свой переопределенный метод toString()
, но это только потоки, ожидающие выполнения.
Есть ли способ получить доступ к потокам, которые в настоящее время выполняются, для вызова моего метода? Или, может быть, есть лучший подход для этой задачи в целом?
Чтобы прояснить немного больше о цели, вот некоторый код общей идеи:
public class GetDataTask implements Runnable {
private String pageNumber;
private int dataBlocksParsed;
private String source;
private String dataType;
public GetDataTask(String source, String dataType) {
this.source = source;
this.dataType = dataType;
}
@Override
public void run() {
//do stuff that affects pageNumber and dataBlocksParsed
}
@Override
public String toString() {
return "GetDataTask{" +
"source=" + source +
", dataType=" + dataType +
", pageNumber=" + pageNumber +
", dataBlocksParsed=" + dataBlocksParsed +
'}';
}
}
и класс, содержащий исполнителя:
public class DataParseManager {
private static ThreadPoolExecutor executor = new ThreadPoolExecutor(100, 100, 20, TimeUnit.SECONDS, new ArrayBlockingQueue<>(300));
public void addParseDataTask(String source, String dataType) {
executor.execute(new GetDataTask(source, dataType));
}
// here's the method that I need
public String getInfo() {
StringBuilder info = new StringBuilder();
//and here's the method that I'm missing - executor.getActiveThreads()
for (Runnable r : executor.getActiveThreads()) {
info.append(((GetDataTask) r).toString()).append('\n');
}
return info.append(executor.toString()).toString();
}
}
Thread.currentThread
, чтобы перейти к потоку, который ее выполняет, и получить информацию. И вы, конечно, можете сохранить ссылки на все отправленные задачи, чтобы получить информацию из них. - person Fildor   schedule 23.02.2016run
, просто добавив с помощью Thread.currentThread и напечатав его имя и идентификатор задачи. - person Fildor   schedule 23.02.2016run
Задач и получать информацию из этого объекта, а не непосредственно из Задач. - person Fildor   schedule 23.02.2016