MDS/openide
1
0
Fork 0
mirror of https://gitflic.ru/project/openide/openide.git synced 2026-09-27 10:03:11 +07:00
Code Issues Packages Projects Releases Wiki Activity

do not execute all the requests to debugger while scrolling (PY-14960)

Browse Source
This commit is contained in:
Liana.Bakradze
2017-04-26 17:19:33 +03:00
parent 95e867eb0e
commit 379f62967b
1 changed files with 11 additions and 6 deletions
Download Patch File Download Diff File Expand all files Collapse all files
python/src/com/jetbrains/python/debugger/array/AsyncArrayTableModel.java
+11 -6
View File
@@ -23,6 +23,8 @@ import com.google.common.util.concurrent.ListenableFutureTask;
import com.intellij.openapi.util.Pair;
import com.intellij.util.ConcurrencyUtil;
import com.intellij.util.ui.UIUtil;
import com.intellij.util.ui.update.MergingUpdateQueue;
import com.intellij.util.ui.update.Update;
import com.jetbrains.python.debugger.ArrayChunk;
import com.jetbrains.python.debugger.ArrayChunkBuilder;
import com.jetbrains.python.debugger.PyDebugValue;
@@ -48,6 +50,7 @@ public class AsyncArrayTableModel extends AbstractTableModel {
private final ExecutorService myExecutorService = ConcurrencyUtil.newSingleThreadExecutor("Python async table");
private final MergingUpdateQueue myQueue = new MergingUpdateQueue("Python async table queue", 100, true, null);
private PyDebugValue myDebugValue;
private final DataViewStrategy myStrategy;
@@ -56,17 +59,13 @@ public class AsyncArrayTableModel extends AbstractTableModel {
@Override
public ListenableFuture<ArrayChunk> load(@NotNull final Pair<Integer, Integer> key) throws Exception {
ListenableFutureTask<ArrayChunk> task = ListenableFutureTask.create(() -> {
return ListenableFutureTask.create(() -> {
ArrayChunk chunk = myDebugValue.getFrameAccessor()
.getArrayItems(myDebugValue, key.first, key.second, Math.min(CHUNK_ROW_SIZE, getRowCount() - key.first),
Math.min(CHUNK_COL_SIZE, getColumnCount() - key.second), myDataProvider.getFormat());
handleChunkAdded(key.first, key.second, chunk);
return chunk;
});
myExecutorService.execute(task);
return task;
}
});
@@ -105,7 +104,13 @@ public class AsyncArrayTableModel extends AbstractTableModel {
}
}
else {
chunk.addListener(() -> UIUtil.invokeLaterIfNeeded(() -> fireTableCellUpdated(row, col)), myExecutorService);
myQueue.queue(new Update("get chunk from debugger") {
@Override
public void run() {
chunk.addListener(() -> UIUtil.invokeLaterIfNeeded(() -> fireTableDataChanged()), myExecutorService);
myExecutorService.execute(((ListenableFutureTask<ArrayChunk>)chunk));
}
});
}
return EMPTY_CELL_VALUE;
}