@ Override public void cancelAllScheduledForActor ( ) { final Set < ActionContext < T > > toCancel ; synchronized ( contexts ) { toCancel = new HashSet <> ( contexts ) ; contexts . clear ( ) ; } // Cancel all toCancel . forEach ( cxt -> { if ( ! cxt . isDone ( ) ) { cxt . cancel ( ) ; } } ) ; }
Cancel all tasks scheduled to the current engine for the actor by this scheduler .