Ленивая загрузка

[Donatte]

Не выдержал, заоффтопил

Пришёл тут велосипедист которому, в отличии от других, не нравится использовать нормальное сиденье, а подавай штырь с резьбой. И тут все сразу кинулись обсуждать тип резьбы. ЗГ такой ЗГ.

[iRevive]

Код:

    @Override
    public void reload() {
        Future<?> future1 = ThreadPoolManager.getInstance().executeGeneral(() -> despawn(XSpawnCache.getInstance().getSpawn(day)));
        Future<?> future2 = ThreadPoolManager.getInstance().executeGeneral(() -> despawn(XSpawnCache.getInstance().getSpawn(night)));
        try {
            future1.get();
            future2.get();
        } catch(ExecutionException e) {
            log.error("Failed to reload event rotator", e);
        } catch(InterruptedException e) {
            Thread.currentThread().interrupt();
            return;
        }
        
        ...
    }

future1 & future2 - асинхронные задачи, которые будут выполняться в любом свободном потоке из пула.
Если в этих тасках будет работа с блокирующим апи(запрос к бд, например), выходит, что метод reload() блокирует сразу 3 потока?

future1.get() - ожидание выполнения задачи, первый заблокированный поток
future1 & future2 - второй и третий заблокированные потоки, если будет работа с блокирующим апи.

Поправьте, если я не прав.

[slayer48]

А разве обычный ThreadPoolManager не выполнит задачу в отдельном потоке?

Достаточно было бы запускать:

Код:

ThreadPoolManager.getInstance().scheduleGeneral(new TheClass(), 1);

В момент "полной" загрузки сервера

Код:

public class TheClass implements Runnable
{
    @Override
    public void run()
    {
        try{
            Connection con = null;
            try
            {
                con = L2DatabaseFactory.getInstance().getConnection();
                PreparedStatement stm = con.prepareStatement("SELECT * FROM special_bosses");
                ResultSet rs = stm.executeQuery();

                while(rs.next())
                {
                    // загрузка, спавн и тд
                                // время загрузки 1 босса ~ 0.5сек
                }
            }
        }
        catch(Throwable t){
            t.printStackTrace();
        }
    }
}

правда как определить момент загрузки сервера хз..

[n3k0nation]

future1 & future2 - асинхронные задачи, которые будут выполняться в любом свободном потоке из пула.
Если в этих тасках будет работа с блокирующим апи(запрос к бд, например), выходит, что метод reload() блокирует сразу 3 потока?

future1.get() - ожидание выполнения задачи, первый заблокированный поток
future1 & future2 - второй и третий заблокированные потоки, если будет работа с блокирующим апи.

Поправьте, если я не прав.

Все верно, но блокировка происходит вызывающего потока.
future1.get - первый заблокированный поток, который и вызывает этот самый гет; блокируется до момента окончания работы future1.
future2.get - тоже самое, тот же самый поток, только блокируется до окончания работы future2.