Skip to content

Commit fecad9e

Browse files
committed
forgot to remove handled async actions from the queue
1 parent e049178 commit fecad9e

File tree

1 file changed

+2
-1
lines changed
  • graalpython/com.oracle.graal.python/src/com/oracle/graal/python/runtime

1 file changed

+2
-1
lines changed

graalpython/com.oracle.graal.python/src/com/oracle/graal/python/runtime/AsyncHandler.java

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -149,7 +149,8 @@ void triggerAsyncActions() {
149149
CompilerDirectives.transferToInterpreter();
150150
// TODO: (tfel) - for now all async actions are slow path
151151
ConcurrentLinkedQueue<AsyncAction> actions = scheduledActions;
152-
for (AsyncAction action : actions) {
152+
AsyncAction action;
153+
while ((action = actions.poll()) != null) {
153154
Object callable = action.callable();
154155
if (callable != null) {
155156
Object[] arguments = action.arguments();

0 commit comments

Comments
 (0)