Программирование, т. 8

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

это рили самое простое что можно придумать

Гений !

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

это рили самое простое что можно придумать

любому человеку не знающему стандартные сортировки если дать задачу наалгоритмить сортировку без вспомогательного массива, то он с 60% шансом выдаст пузырёк, 40% вставку

Откуда ты это знаешь  monkas

Откуда ты это знаешь  monkas

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

зашел в твитер а там (если аже iq это пишет, то дела у раста очень плохи)

зашел в твитер а там (если аже iq это пишет, то дела у раста очень плохи)

это фотожоп, нас не обманешь

 

тебя же забанили везде, сиди в спутнике и не вкидывай дезинфу

зашел в твитер а там (если аже iq это пишет, то дела у раста очень плохи)

вообще-то foreach это нестандартное расширение от visualc++ и даже microsoft не рекомендует его использовать

откуда ты это взял?

в мсвс+++ нет такого

 

в плюсах вместо этого просто for (T &elem : collection) есть с обычным фор

Как же у вас тут душно поцаны

Неужто крупный ИТ-ресурс не может сделать адекватный адаптивный дизайн? 

а нахуя? они и так крупные, им незачем этим привлекать  аудиторию

Тут же есть эксперты жавы.

 

Вопрос

Thread thread = Thread.currentThread();
        System.out.println("BaS" + thread.toString());
        CompletableFuture.supplyAsync(() -> {
            System.out.println("InAs" + Thread.currentThread().toString());
            return "E";
        }).whenComplete((s, throwable) -> {
            System.out.println("OutAs" + Thread.currentThread().toString());
        });

Почему whenComplete иногда запускается в BaS треде как надо, а иногда в форкджоин пуле.

BaSThread[task-4,5,main]
InAsThread[ForkJoinPool.commonPool-worker-2,5,main]
BaSThread[task-6,5,main]
InAsThread[ForkJoinPool.commonPool-worker-2,5,main]
OutAsThread[ForkJoinPool.commonPool-worker-2,5,main]
BaSThread[task-1,5,main]
InAsThread[ForkJoinPool.commonPool-worker-5,5,main]
OutAsThread[ForkJoinPool.commonPool-worker-5,5,main]
OutAsThread[task-4,5,main]

Например. Только один OutAsThread[task-4,5,main] вернулся в тред родитель. Вчом смысл тогда whenComplete от whenCompleteAsync когда у первого нет гарантии синхронного поведения.

откуда ты это взял?

в мсвс+++ нет такого

 

в плюсах вместо этого просто for (T &elem : collection) есть с обычным фор

 

переносил билд с++ кода на линукс с винды и менял for each (item in collection) на for (item : collection)

Изменено 11 февраля 2019 пользователем DDamager

Ладно я понял как запускаются методы CompletableFuture, но я бы сделал иначе или расширил, чтобы можно было создавать ранаблы и колаблы блокирующие родительский поток хотя бы.

Ладно я понял как запускаются методы CompletableFuture, но я бы сделал иначе или расширил, чтобы можно было создавать ранаблы и колаблы блокирующие родительский поток хотя бы.

ну так понял - поясни

Тут же есть эксперты жавы.

 

Вопрос

Thread thread = Thread.currentThread();
        System.out.println("BaS" + thread.toString());
        CompletableFuture.supplyAsync(() -> {
            System.out.println("InAs" + Thread.currentThread().toString());
            return "E";
        }).whenComplete((s, throwable) -> {
            System.out.println("OutAs" + Thread.currentThread().toString());
        });

Почему whenComplete иногда запускается в BaS треде как надо, а иногда в форкджоин пуле.

BaSThread[task-4,5,main]
InAsThread[ForkJoinPool.commonPool-worker-2,5,main]
BaSThread[task-6,5,main]
InAsThread[ForkJoinPool.commonPool-worker-2,5,main]
OutAsThread[ForkJoinPool.commonPool-worker-2,5,main]
BaSThread[task-1,5,main]
InAsThread[ForkJoinPool.commonPool-worker-5,5,main]
OutAsThread[ForkJoinPool.commonPool-worker-5,5,main]
OutAsThread[task-4,5,main]

Например. Только один OutAsThread[task-4,5,main] вернулся в тред родитель. Вчом смысл тогда whenComplete от whenCompleteAsync когда у первого нет гарантии синхронного поведения.

в твоих логах не понятно что OutAsThread[task-4,5,main]

относится к BaSThread[task-4,5,main]

передавай id какойнибудь чтобы можно было отслеживать что это один и тот же проход

вполне может быть что OutAsThread[task-4,5,main] - это уже освободившийся первый 

 

 

собственно - https://docs.oracle.com/javase/8/docs/api/java/util/concurrent/CompletableFuture.html

погуглить то перед тем как задавать вопрос, несудьба?

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

что блять

Изменено 11 февраля 2019 пользователем Just.Doit

 

откуда ты это взял?

в мсвс+++ нет такого

 

в плюсах вместо этого просто for (T &elem : collection) есть с обычным фор

 

переносил билд с++ кода на линукс с винды и менял for each (item in collection) на for (item : collection)

 

хм, TIL

 

я думал там был бы такой же синтакс как у сшарповского "foreach" и ничего в доках не находил

плюс в оригинальном посте тоже было foreach, а не for each

 

 

что блять

 

 CompletableFuture.supplyAsync(() -> {
            System.out.println("InAs" + Thread.currentThread().toString());
            return "E";
        }).whenComplete((s, throwable) -> {
            for (int i = 0; i < 100; i++) { //чтобы этот ранабл
                list.add(i);
            }
        });
        //блокировал этот поток что не понятно то блять
        list.forEach(System.out::println); //ConcurentModification

 

 

ну так понял - поясни

 

Ну таск выполняется CompletableFuture без асинхронности выполняется либо в потоке из цепочки выше, либо в потоке get либо в потоке где он родился.

У меня было 2 кондишона.

        CompletableFuture.supplyAsync(() -> {
        })
        .whenComplete((s, throwable) -> { //если лямбда выше успела выполниться до создания этой, то эта биндилась к основному потоку, если же лямбда выше ещё выполняется, то к ней биндится эта
        });

 

что блять

 

 CompletableFuture.supplyAsync(() -> {
            System.out.println("InAs" + Thread.currentThread().toString());
            return "E";
        }).whenComplete((s, throwable) -> {
            for (int i = 0; i < 100; i++) { //чтобы этот ранабл
                list.add(i);
            }
        });
        //блокировал этот поток что не понятно то блять
        list.forEach(System.out::println); //ConcurentModification

 

 

ну так понял - поясни

 

Ну таск выполняется CompletableFuture без асинхронности выполняется либо в потоке из цепочки выше, либо в потоке get либо в потоке где он родился.

У меня было 2 кондишона.

        CompletableFuture.supplyAsync(() -> {
        })
        .whenComplete((s, throwable) -> { //если лямбда выше успела выполниться до создания этой, то эта биндилась к основному потоку, если же лямбда выше ещё выполняется, то к ней биндится эта
        });

 

что блять

 

 CompletableFuture.supplyAsync(() -> {
            System.out.println("InAs" + Thread.currentThread().toString());
            return "E";
        }).whenComplete((s, throwable) -> {
            for (int i = 0; i < 100; i++) { //чтобы этот ранабл
                list.add(i);
            }
        });
        //блокировал этот поток что не понятно то блять
        list.forEach(System.out::println); //ConcurentModification

 

 

ну так понял - поясни

 

Ну таск выполняется CompletableFuture без асинхронности выполняется либо в потоке из цепочки выше, либо в потоке get либо в потоке где он родился.

У меня было 2 кондишона.

        CompletableFuture.supplyAsync(() -> {
        })
        .whenComplete((s, throwable) -> { //если лямбда выше успела выполниться до создания этой, то эта биндилась к основному потоку, если же лямбда выше ещё выполняется, то к ней биндится эта
        });

чтобы лямбда внутри фьючи не может блокировать исходный поток сама по себе. можно в исходном потоке написать блокировку которая будет ждать выполнения фьючи

 

зачем нужен отдельно метод whenComplete (в отличае от его async версии ) - наверное кейс какой-то такой - у тебя забит пул, и ты в качестве оптимизации хочешь чтобы в текущем треде тогда вычислялась фьюча. а если тебе такая оптимизация наоборот ухудшит перформанс и хочешь чтобы всегда всё вбрасывалось в пул - пишешь async версию

 

на самом деле реальный кейс использования тоже интересен, найдешь ссылку - скинь. на SO за 5 паервых ссылок я чето не нашел