Остановка ScheduledFuture

[coldy]

Немного зашел в тупик, поэтому не откажусь от совета.

Вопрос в следующем. Как корректно закрыть таск, ссылка на который записывается в _delayedTask?
Проблема в том, что таск создается несколько раз (собственно видно из цикла и по сути ссылка перезаписывается).
Где должен закрываться _delayedTask видно по коду.

 
 
static class TaskTemporaryHero implements Runnable
    {
        ArrayList<Integer> _players = null;
 
        @Override
        public void run() {
            _players = getTopPvpPlayer();
            if (_players != null && !_players.isEmpty())
            {
                for (Integer charId : _players)
                {
                    L2PcInstance player = L2World.getPlayer(charId);
                    Calendar cal = Calendar.getInstance();
                    cal.setTimeInMillis(System.currentTimeMillis());
                    cal.add(Calendar.MINUTE,HERO_TIME);
                    if (player == null) // На случай, если не был онлайн во время выдачи награды
                        _delayedTask = ThreadPoolManager.scheduleAtFixedRate(new TaskDelayedTemporaryHero(charId,cal.getTimeInMillis()), 1000, 60000);
                    else if (!checkCondition(player))
                        _delayedTask = ThreadPoolManager.scheduleAtFixedRate(new TaskDelayedTemporaryHero(charId,cal.getTimeInMillis()), 1000, 60000);
                    else
                        TemporaryHeroTask.setTemporaryHero(player);
                }
            }
            else
                _log.info("TemporaryHeroHask : there is no players to set Hero for top PvP.");
        }
    }
 
    static class TaskDelayedTemporaryHero implements Runnable
    {
        int _charId = 0;
        long _time = 0;
 
        TaskDelayedTemporaryHero(int charId, long time)
        {
            _charId = charId;
            _time = time;
        }
 
        @Override
        public void run() {
            if (_charId != 0)
            {
                L2PcInstance player = L2World.getPlayer(_charId);
                if (player != null && checkCondition(player))
                {
                    setDelayedTemporaryHero(player,_time);
                    _delayedTask.cancel(true);
                }
            }
            else
                _log.warn("TaskDelayedTemporaryHero : charId = 0");
        }
    }
 
 
Code: Java

Перетащить ссылку вместе с таском поидее не получится, ибо по логике вещей описанное ниже работать не будет.

 
_delayedTask = ThreadPoolManager.scheduleAtFixedRate(new TaskDelayedTemporaryHero(charId,cal.getTimeInMillis(), _delayedTask), 1000, 60000);
 
Code: Java

ЗЫ: За гавнокод просьба не ругать.

[hex1r0]

псевдокод:

TaskDelayedTemporaryHero closer = new TaskDelayedTemporaryHero(charId,cal.getTimeInMillis());
closer.setTask(ThreadPoolManager.scheduleAtFixedRate(closer , 1000, 60000));

....

static class TaskDelayedTemporaryHero implements Runnable
    {
        ...
        Future<?> _delayedTask;
        
        ...
 
        void setTask(Future<?> task) 
       {
             _delayedTask = task;
       }
    }

[Yorie]

Может быть следует хранить список или мапу тасков? Можно цеплять, например, по charId.
И, собственно, зачем куча тасков под каждого игрока? Передавайте в Runnable список игроков и будет у Вас один таск. Не думаю, что в этом классе очень уж критично параллельная выдача временного геройства для каждого игрока.

// Отдать Future в сам таск тоже оригинально

[coldy]

Сообщение от Yorie

И, собственно, зачем куча тасков под каждого игрока? Передавайте в Runnable список игроков и будет у Вас один таск.

В любом случае получится 2 списка. Те кто готов получить геройство и те кто либо не онлайн, либо не удовлетворяет условиями. На первый взгляд в плане кода получаются огороды. Хотя таски под каждого персонажа такие же огороды. Вообщем попробуемс и по вашему варианту

В целом разобрался. Спасибо всем, кто откликнулся.

[учусь]

// del, не смотрел ответы