JavaRush/Помощь по Java задачам/Не принимает 4 и 5 пункты, но все выводит согласно услови...

44 уровень

01.10.2023
298просмотров
7комментариев

Не принимает 4 и 5 пункты, но все выводит согласно условию.

Вопрос по задаче

Java Multithreading, 8 уровень, 4 лекция

Решен

firstGroup-pool-1-thread-1
firstGroup-pool-1-thread-2
secondGroup-pool-2-thread-1
secondGroup-pool-2-thread-2
secondGroup-pool-2-thread-3

В классе Solution создай публичный статический класс AmigoThreadFactory, реализующий интерфейс ThreadFactory.
1. Реализация интерфейсного метода - создай и верни трэд, который должен:
1.1. не быть демоном,
1.2. иметь нормальный приоритет,
1.3. имя трэда должно иметь шаблон "GN-pool-A-thread-B",
где GN - это имя группы,
A - это номер фабрики инкрементируется в пределах класса начиная с 1, используй AtomicInteger,
B - номер треда инкрементируется в пределах конкретной фабрики начиная с 1, используй AtomicInteger.
2. Каждая фабрика должна иметь ту группу тредов (ThreadGroup), в которой она была создана.
3. Методы main и emulateThreadFactory не участвуют в тестировании.

Пример вывода:
secondGroup-pool-2-thread-1 firstGroup-pool-1-thread-1 firstGroup-pool-1-thread-3 secondGroup-pool-2-thread-3 firstGroup-pool-1-thread-2 secondGroup-pool-2-thread-2

Требования:

В классе Solution нужно создать класс public static AmigoThreadFactory, который реализует интерфейс ThreadFactory.
Фабрика AmigoThreadFactory должна создавать трэды, которые не являются демоном.
Фабрика AmigoThreadFactory должна создавать трэды, которые имеют нормальный приоритет.
Фабрика AmigoThreadFactory должна создавать имена для трэдов по шаблону "GN-pool-A-thread-B".
Каждая фабрика должна производить трэды с группой (ThreadGroup), в которой она была создана.

package com.javarush.task.task28.task2802; import java.util.concurrent.ThreadFactory; import java.util.concurrent.atomic.AtomicInteger; /* Пишем свою ThreadFactory */ public class Solution { public static void main(String[] args) { class EmulatorThreadFactoryTask implements Runnable { @Override public void run() { emulateThreadFactory(); } } ThreadGroup group = new ThreadGroup("firstGroup"); Thread thread = new Thread(group, new EmulatorThreadFactoryTask()); ThreadGroup group2 = new ThreadGroup("secondGroup"); Thread thread2 = new Thread(group2, new EmulatorThreadFactoryTask()); thread.start(); thread2.start(); } private static void emulateThreadFactory() { AmigoThreadFactory factory = new AmigoThreadFactory(); Runnable r = new Runnable() { @Override public void run() { System.out.println(Thread.currentThread().getName()); } }; factory.newThread(r).start(); factory.newThread(r).start(); factory.newThread(r).start(); } public static class AmigoThreadFactory implements ThreadFactory { private static final AtomicInteger poolNumber = new AtomicInteger(1); private final int namePrefix; private final AtomicInteger treadNumber = new AtomicInteger(); private final ThreadGroup group; private AmigoThreadFactory() { namePrefix = poolNumber.getAndIncrement(); group = Thread.currentThread().getThreadGroup(); } @Override public Thread newThread(Runnable r) { Thread tr = new Thread(group, r); tr.setName(tr.getThreadGroup().getName() + "-pool-" + namePrefix + "-thread-" + treadNumber.incrementAndGet()); if (tr.isDaemon()) tr.setDaemon(false); if (tr.getPriority() != Thread.NORM_PRIORITY) tr.setPriority(Thread.NORM_PRIORITY); return tr; } } }

Комментарии (7)

популярные
новые
старые

Для того, чтобы оставить комментарий Вы должны авторизоваться

very junior java developer

Уровень 51

3 октября 2023, 19:30

полезный

Thread tr = new Thread(group, r); // это странно

конструкторов у Thread много разных, но я думаю надо использовать тот, который первым аргументом принимает объект реализующий Runnable, вторым имя потока. Группу ему не надо назначать, там же выше в коде от разрабов есть присвоение группы потоку при создании. я бы метод newThread передал как-то так:

1) форматируем строку для name по условию.
2) создаём поток с конструктором new Thread(Runnable r, String name);
3) Выставляем thread.setDaemon(false); и thread.setPriority(Thread.NORM_PRIORITY); думаю можно и без if
4)возвращаем созданный Thread

далее что касается полей класса AmigoThreadFactory (просто проставлю коменты):

private static final AtomicInteger poolNumber = new AtomicInteger(1); // она у тебя получается всегда 1 будет??)) сделай new AtomicInteger(0) а инициализируй в конструкторе (ниже коммент)
private final int namePrefix; // не понятно зачем это??
private final AtomicInteger treadNumber = new AtomicInteger(); //не помню точно, но помоему важно указывать начальное значение, хотя может ошибаюсь, в лом проверять, уточни
private final ThreadGroup group; // это лучше заменить на String groupName

private AmigoThreadFactory() {
    namePrefix = poolNumber.getAndIncrement(); // не понятно зачем
    group = Thread.currentThread().getThreadGroup(); // а здесь тогда group = Thread.currentThread().getThreadGroup().getName();
    //тут ещё бы можно сразу проинициализировать poolNumber = factoryNumber.incrementAndGet(); (смотри выше коммент к полю poolNumber )
}

на основе вышесказанного строка name будет выглядеть как-то так String.format("%s-pool-%d-thread-%d", groupName, poolNumber.get(), threadNumber.incrementAndGet())

very junior java developer

Уровень 51

3 октября 2023, 19:32

Я описал всё кратко, местами не разжёвывая что и почему, так что если что-то не понятно - уточняй

Grock

Уровень 44

9 октября 2023, 15:20

Спасибо большущее за такой подробный расклад и уделенное время)) Все понятно)

Grock

Уровень 44

9 октября 2023, 15:20

public static class AmigoThreadFactory implements ThreadFactory {
    private static final AtomicInteger poolNumber = new AtomicInteger(0);
    private final int poolNumberName;
    private final AtomicInteger treadNumber = new AtomicInteger();
    private final String groupNAme;

    private AmigoThreadFactory() {
        poolNumberName = poolNumber.incrementAndGet();
        groupNAme = Thread.currentThread().getThreadGroup().getName();
    }

    @Override
    public Thread newThread(Runnable r) {
        String threadName = groupNAme +
                "-pool-" +
                poolNumberName +
                "-thread-" +
                treadNumber.incrementAndGet();
        Thread tr = new Thread(r, threadName);
            tr.setDaemon(false);
            tr.setPriority(Thread.NORM_PRIORITY);
        return tr;
    }
}

Grock

Уровень 44

9 октября 2023, 15:26

Сделал так. Не приняло.

private static final AtomicInteger poolNumber = new AtomicInteger(1);
// она у тебя получается всегда 1 будет??)) сделай new AtomicInteger(0) а инициализируй в конструкторе (ниже коммент)

Я ниже в конструкторе сначала получал, а потом инкрементировал значение (что неправильно), а результат записывал в переменную объекта, поэтому при новой инициализации объекта (группы) к poolNumber прибавлялось 1.

private final int namePrefix; // не понятно зачем это??

Поскольку статическая переменная принадлежит классу, а не объекту, если мы не будем записывать ее результат для каждого объекта, то она будет одинаково называться для обоих групп. Именно поэтому я записываю в переменную namePrefix (да, название не корректное) инкрементированную переменную poolNumber, чтобы она была едина для объекта класса AmigoThreadFactory.

private final AtomicInteger treadNumber = new AtomicInteger();
//не помню точно, но помоему важно указывать начальное значение, хотя может ошибаюсь, в лом проверять, уточни

Попробую сейчас.. упустил коммент из виду)

private final ThreadGroup group; // это лучше заменить на String groupName

Заменил.

private AmigoThreadFactory() {
    namePrefix = poolNumber.getAndIncrement(); // не понятно зачем

Выше пояснил.

group = Thread.currentThread().getThreadGroup();
// а здесь тогда group = Thread.currentThread().getThreadGroup().getName();

Сделал.

//тут ещё бы можно сразу проинициализировать poolNumber = factoryNumber.incrementAndGet(); (смотри выше коммент к полю poolNumber )

Сделал. Спасибо :)

Grock

Уровень 44

9 октября 2023, 15:31

private final AtomicInteger treadNumber = new AtomicInteger(); //не помню точно, но помоему важно указывать начальное значение, хотя может ошибаюсь, в лом проверять, уточни

Сделал так, но также без изменений:

private final AtomicInteger treadNumber = new AtomicInteger(0);

Grock

Уровень 44

9 октября 2023, 15:41

решение

В общем, упростил до такого вида, полностью убрав конструктор. Тогда только приняло, хотя принципиально ничего не менял. Значит дело в конструкторе. Он здесь лишний. Иных догадок нет у меня)))

public static class AmigoThreadFactory implements ThreadFactory {
    private static final AtomicInteger poolNumber = new AtomicInteger(0);
    private final AtomicInteger treadNumber = new AtomicInteger(0);
    private final String threadName = Thread.currentThread().getThreadGroup().getName() +
            "-pool-" +
            poolNumber.incrementAndGet() +
            "-thread-";;
    @Override
    public Thread newThread(Runnable r) {
        Thread tr = new Thread(r, threadName +
                treadNumber.incrementAndGet());
            tr.setDaemon(false);
            tr.setPriority(Thread.NORM_PRIORITY);
        return tr;
    }
}