ИВ
В том то и дело что просто нуллПоинтерЕксепшен, и непонятно что вообще не так
если Аппликейшн этот с @Springbootapplication, то поему надо @SpringBootTest использовать
дао не понятно тебе надо чтоб инжектилось, а ты сам инициализируешь
Size: a a a
2020 August 17
GI
Э
Вам нравится читать код проксей спринговых?
D
Илья Высоцкий
Нагуглил такой вот вариант, и не пойму как докрутить чтоб работало. Вроде все есть, база есть, темплейт есть, дао есть. Все должно посвязываться и заработать. ан нет. Подскажите кто может.
на скриншоте код написан неправильно
D
Илья Высоцкий
валится на 49 строчке, нуллПоинтерЕксепшн. Значит ли это что база хоть поднялась и работает? или не обязательо?
ты можешь просто уделить время и прочитать про тесты в спринг буте?
D
про JUnit5, @SpringBootTest, TestContainers
D
как работает @Autowired
D
у тебя бред несусветный написан
D
GI
вот да. конструктивный фидбек)
D
полностью противоречит идеи спринга
RG
подскажите пожалуйста, почему не отрабатывает прерывание в многопоточности?
есть основной поток в котором задаю
ExecutorService executor = Executors.newFixedThreadPool(threadCount);
for (String camera : cameras) {
executor.submit(
() -> {
...
while (attempts < 200) {
if (!Thread.currentThread().isInterrupted()) { //////////// здесь всегда возвращается true
log.info(Thread.currentThread().isInterrupted()) //вывод всегда false
}
другом потоке я вызываю
executor.shutdownNow();
есть основной поток в котором задаю
ExecutorService executor = Executors.newFixedThreadPool(threadCount);
for (String camera : cameras) {
executor.submit(
() -> {
...
while (attempts < 200) {
if (!Thread.currentThread().isInterrupted()) { //////////// здесь всегда возвращается true
log.info(Thread.currentThread().isInterrupted()) //вывод всегда false
}
другом потоке я вызываю
executor.shutdownNow();
DS
Rinchin G
подскажите пожалуйста, почему не отрабатывает прерывание в многопоточности?
есть основной поток в котором задаю
ExecutorService executor = Executors.newFixedThreadPool(threadCount);
for (String camera : cameras) {
executor.submit(
() -> {
...
while (attempts < 200) {
if (!Thread.currentThread().isInterrupted()) { //////////// здесь всегда возвращается true
log.info(Thread.currentThread().isInterrupted()) //вывод всегда false
}
другом потоке я вызываю
executor.shutdownNow();
есть основной поток в котором задаю
ExecutorService executor = Executors.newFixedThreadPool(threadCount);
for (String camera : cameras) {
executor.submit(
() -> {
...
while (attempts < 200) {
if (!Thread.currentThread().isInterrupted()) { //////////// здесь всегда возвращается true
log.info(Thread.currentThread().isInterrupted()) //вывод всегда false
}
другом потоке я вызываю
executor.shutdownNow();
А что ты именно хочешь увидеть? Ты же логгируешь только есть !isInterrupted()?
DS
Rinchin G
подскажите пожалуйста, почему не отрабатывает прерывание в многопоточности?
есть основной поток в котором задаю
ExecutorService executor = Executors.newFixedThreadPool(threadCount);
for (String camera : cameras) {
executor.submit(
() -> {
...
while (attempts < 200) {
if (!Thread.currentThread().isInterrupted()) { //////////// здесь всегда возвращается true
log.info(Thread.currentThread().isInterrupted()) //вывод всегда false
}
другом потоке я вызываю
executor.shutdownNow();
есть основной поток в котором задаю
ExecutorService executor = Executors.newFixedThreadPool(threadCount);
for (String camera : cameras) {
executor.submit(
() -> {
...
while (attempts < 200) {
if (!Thread.currentThread().isInterrupted()) { //////////// здесь всегда возвращается true
log.info(Thread.currentThread().isInterrupted()) //вывод всегда false
}
другом потоке я вызываю
executor.shutdownNow();
2020 August 18
RG
А что ты именно хочешь увидеть? Ты же логгируешь только есть !isInterrupted()?
Я понял в чем у меня проблема, в executors помимо того что я записываю log.info
я еще обращаюсь webclient'ом к ресурсу и пытаюсь забрать данные
webClient
.get()
.uri(urlLink)
.header("X-Requested-With", "XMLHttpRequest")
.exchange()
.flatMap(response -> {
if (!response.statusCode().is2xxSuccessful()) {
return Mono.error(new RuntimeException("Internal server error"));
} else {
return response.bodyToMono(ByteArrayResource.class);
}
}).map(ByteArrayResource::getByteArray)
.block(); < < ——————————проблема здесь
Из за метода block не может завершиться поток
без него все работает хорошо,
а вот как это решить пока без понятия
я еще обращаюсь webclient'ом к ресурсу и пытаюсь забрать данные
webClient
.get()
.uri(urlLink)
.header("X-Requested-With", "XMLHttpRequest")
.exchange()
.flatMap(response -> {
if (!response.statusCode().is2xxSuccessful()) {
return Mono.error(new RuntimeException("Internal server error"));
} else {
return response.bodyToMono(ByteArrayResource.class);
}
}).map(ByteArrayResource::getByteArray)
.block(); < < ——————————проблема здесь
Из за метода block не может завершиться поток
без него все работает хорошо,
а вот как это решить пока без понятия