Сергей Горностаев

Вам стоит внимательнее перечитать документацию Channels, под WSGI они не работают. Вам надо чем-нибудь, типа supervisord, запустить отдельно воркеры и отдельно ASGI-сервер Daphne. Nginx необходимо настроить на проброс запросов к Daphne. Кроме того, вам нужен какой-нибудь брокер очереди, например, Redis.

В asyncio есть несколько слоев абстракций более высокого уровня, лучше работать с ними. Но если уж хочется работать непосредственно с сокетами, то стоит учесть, что socket.recv() - это блокирующийся метод, а потому использовать его с await не выйдет. Необходимо использовать асинхронную обёртку для него:

data = yield from asyncio.get_event_loop().sock_recv(self.__conn, 256)

Ваш вопрос решается на уровне модулей: объявляете классы в пакете публичными, но не экспортируете их в модуле.

Из документации:

Sends are delayed until consumer completion. To override this, you may pass immediately=True.

Channel('some-channel').send(message, immediately=True)

Thymeleaf тут вообще не при чём. Ошибка связана с тем, что у вас после вызова response.sendRedirect("/admin") вызывается filterChain.doFilter(req, resp);. После редиректа обработку запроса надо прерывать :

try {
    response.sendRedirect("/admin");
    return;
} catch (IOException e) {
    e.printStackTrace();
}

Подключиться к базе с помощью psql, ввести \timing и выполнять интересующие вас запросы.

В этом и суть. Насколько сложен вопрос именно для меня, столько и ставлю. Итоговая сложность вопроса определяется большинством голосов. Если большинство считает, что вопрос простой - значит он простой.

50 - это немного :) Много - это несколько тысяч. Лучше используйте асинхронность вместо многопоточности. В Python это и проще и производительнее в большинстве случаев.

int numbers[] = new int[] {1, 2, 3, 4, 4, 5, 6, 7, 7, 8, 8, 8, 9};

int number = Arrays.stream(numbers)
               .filter(n -> n % 2 == 0)
               .boxed()
               .collect(
                 Collectors.groupingBy(
                   Function.identity(),
                   Collectors.counting()))
               .entrySet()
               .stream()
               .max(Map.Entry.comparingByValue(Long::compareTo))
               .map(Map.Entry::getKey)
               .get();

Принимать и передавать так, как описано в задаче. Только часть "То есть работать в виде: solution.exe output.dat" противоречит всему остальному тексту.

Замапить легко

@Entity
public class Zone {
    @Id
    @GeneratedValue(strategy = GenerationType.AUTO)
    private Long id;

    @OneToOne(mappedBy = "zone")
    private ZoneDescription description;

    // Геттеры и сеттеры не указаны для краткости
}

@Entity
public class ZoneDescription {
    @Id
    @GeneratedValue(strategy = GenerationType.AUTO)
    private Long id;

    @OneToOne
    private Zone zone;

    @ManyToOne(optional = false)
    private ZoneLanguage language;

    // Геттеры и сеттеры не указаны для краткости
}

@Entity
public class ZoneLanguage {
    @Id
    @GeneratedValue(strategy = GenerationType.AUTO)
    private Long id;

/*  Раскоментировать, если нужна двунаправленная связь
    @OneToMany(mappedBy = "language")
    private Set<ZoneDescription> descriptions = new HashSet<>();
*/

    // Геттеры и сеттеры не указаны для краткости
}

И потом так же легко в прикладном коде

Zone zone = zoneRepository.getById(zoneId);
ZoneDescription description = zone.getDescription();

Во-первых, таск должен быть Abortable:

from celery.contrib.abortable import AbortableTask

@app.task(bind=True, base=AbortableTask)
def testtask(self):
    ...

Во-вторых, вместо while True: надо while not self.is_aborted():

Десять соединений от клиентов подключены к интерфейсному процессу - серверу Daphne. Запросы, приходящие через эти соединения, передаются в очередь, например Redis. А оттуда уходят воркерам, которые последовательно запускают синхронные обработчики. Если воркеров у вас 5 и одновременно пришло 10 запросов к вьюхе, которой на ответ нужна секунда, то 5 клиентов получат ответ через секунду, а ещё 5 через две. Django Channels - это почти как Django + Celery. Основная разница только в возможности удерживать множество открытых соединений.

Если нужна полноценная асинхронность, то лучше посмотреть в сторону aiohttp.

Если полноценный exe, то использовать AOT-компилятор, типа Excelsior JET. Но они все платные и весьма недешёвые.

Есть ещё вариант упаковать java-приложение в exe. Например, с помощью launch4j. Но это костыль, по сути просто самораспаковывающийся архив, содержащий jar-файл и jre для его запуска.

Вам нужно явно присвоить значение полю company:

public void addGroup(Group group) {
    group.setCompany(this);
    groups.add(group);
}

и тогда Hibernate сделает всё остальное.