윈도우10보다 이상이면 리눅스 프로그래밍 안되는걸까요??

안녕하세요! 비동기 프로그래밍을 해야되는데 너무 어려워서 강의를 등록했습니다!개인적인 궁금증인데 다중화된 서버일 경우, 비동기 호출하게 되면 리턴을 호출한 서버가 받게 되는걸까요?아니면 다른 서버가 받을 수도 있는걸까요?혹시 호출 서버가 받는게 보장된다면 그건 어디서 보장을 해주는 걸까요?

안녕하세요 선생님, 강의를 듣다가 의문점이 드는 설명이 있어서 질문 올립니다.[keepAliveTime - 스레드 유휴 시간 설정] 강의03:56 ~ 04:20 의 설명을 듣고 나서 처음에는 끄덕였는데,강의를 다 듣고 나니까 뭔가 의문점이 생겼습니다.해당 시간대에 설명에서는 Thread.sleep(3000) 메소드가 유휴상태를 일으키고, 이것 때문에 keepAliveTime 에 의해서 쓰레드가 제거된다고 설명해주십니다.이때 듣고 나서 아래와 같은 생각을 하게 되더라구요."그러면 Thread.sleep(3000) 을 하고, KeepAliveTime 을 2초를 줘서 정말 저 3초가 지나기 전에 쓰레드가 삭제되야 된다면 쓰레드가 제거되기 전에 InterruptedException 같은 걸 던지려나?" ... 라는 생각을 하게 되더라구요.그리고 제가 한 테스트 결과는 그렇지 않더군요...이상해서 이리저리 찾아보니 다음과 같은 설명을 jdk 소스 파일에서 발견했습니다. 여기서 제가 주목한 구절은 "Timeout in nanoseconds for idle threads waiting for work." 입니다.이 말은 Thread 가 sleep 같은 상태에서 멈추더라도,해당 Thread 는 "다음 일을 받기 위해서 대기하는 쓰레드" 가 아니기 때문에 keepAliveTime 에 의해서 제거되는 타겟이 아니지 않나요?더 정확히는...keepAliveTime 의 유휴시간은==> Thread.sleep(3000) 에서 유휴시간 Check X==> 쓰레드가 자기의 task 를 모두 끝난 직후부터 유휴시간 Check O... 인 게 맞지 않나요?

안녕하세요. 선생님 sleep() 강의를 듣다가 sleep(0) 메서드 관련해서 질문이 생겨서 질문을 남기게 되었습니다! sleep() 강의 중 12:25 내용을 보면, sleep을 진행하려는 Thread의 priority가 5라서 동일한 우선순위인 5인 Thread가 있는지 찾아본다고 말씀을 해주셨는데요. 제가 여기서 궁금한 점은 반드시 동일한 우선순위의 Thread만을 확인하는지가 궁금합니다. 만약 동일한 우선순위인 우선순위가 5인 Thread는 없더라도, 더 높은 우선순위의 Thread가 존재해도 컨텍스트 스위칭이 일어나지 않는 것일까요 ??    

설명을 잘 해주셔서 이해가 잘 됐습니다.node js 에서는 싱글 스레드로 돌아가고 있고 ,코드를 작성하게 될때 , async await 를 붙여서동시성 작업을 많이 하는걸로 알고있습니다. 이는 싱글스레드라 할지라도 엔진상 속도가 잘 나오기 때문에 괜찮다고 들었는데요 python 입장에서는 어떤가요 ??

NamedLockFacade에서@Transactional public void decrease(Long id, Long quantity) { try { lockRepository.getLock(id.toString()); stockService.decrease(id, quantity); } finally { lockRepository.releaseLock(id.toString()); } }락 획득을 하지 못해도 releaseLock이 실행되서 락을 해제하는 코드입니다.락을 획득하지 못해도 락을 해제하려고 하는데 따로 문제가 발생하진 않나요?

안녕하세요 강사님. 1부에는 이런 내용이 없는 것 같은데, 2부나 3부에 WebFlux나 Reactor에 대한 내용도 강의해주시나요?

선생님 안녕하세요. 강의를 듣다가 조금 이상한 부분이 있어서 문의드립니다.[ 스레드 풀 이해와 구현 ] 강의에서 작성하는 코드를 저도 그대로 따라치면서 실습을 하고 있는데요.그런데 예시 코드의 동작에 약간의 문제를 발견했습니다. 강의에서 보여주는 코드는 아래와 WorkerThread 코드는 아래와 같습니다. 그런데 제가 한 ThreadPoolMain 클래스에서 Task 를 3000 개 정도 주고, ThreadPoolSize =20 을 주고 돌려보니까, 2가지 이상현상을 확인했습니다.1. Null Poiniter Exception 발생중복 처리각각의 문제가 발생하는 이유를 정리해보니 다음과 같더라구요. NPE 발생 원인// 시나리오 1 if (!taskQueue.isEmpty()) { // 쓰레드 A,B 2개가 동시에 여기에 접근 // 쓰레드 A 가 먼저 Poll 을 해서 가져가버림. // 쓰레드 B 는 비어있는 Queue 에 대하여 poll, null 을 반환 받음 task = taskQueue.poll(); } else { continue; } // 쓰레드 A 는 정상 시작 // 쓰레드 B 는 NullPointerException! task.run(); 중복처리 원인// 시나리오 2 if (!taskQueue.isEmpty()) { // 쓰레드 A,B 2개가 동시에 여기에 접근 // 쓰레드 A 가 먼저 Poll 을 해서 가져 가버림. // 쓰레드 B 도 Poll 해서 task 를 가져감. task = taskQueue.poll(); } else { continue; } // 쓰레드 A 는 작업 시작 // 쓰레드 B 도 중복으로 해당 task 실행 task.run(); 혹시 코드를 아래처럼 짜야 되는 게 아닌지 조심스럽게 문의해봅니다.  

안녕하세요. 비동기 작업 조합 강의 38분 30초대를 듣다가 질문이 생겼습니다. 인텔리제이 콘솔에 '최종 결과: 10'으로 출력되고 있는데요.궁금한 점은 아래와 같습니다.비동기 처리 과정이 제일 적은 cf1의 리턴 값은 10이다AnyOfExample.java 19 Line에서는 result * 10으로 계산이 되고 있다.따라서 100이 나올 것으로 예상을 했는데 10으로 출력되는 것으로 보아 2번 계산 과정을 스레드가 실행하지 않은 건가 싶어서요.혹시 제가 놓치고 있는 부분이 있나 해서 질문드립니다.

강사님 안녕하세요!해당 강의 수강 후 실무에 재고 동시성 처리 코드를 개발하고 있는데 궁금한 부분이 있어서 문의드립니다! redisson lock 으로 구현하였는데, 중복 코드가 많아서 AOP로 작업 작업을 하려합니다.aop를 작업 하는 경우 facade가 아니라 stockService에 직접 어노테이션을 추가하는 형태로 하는게 맞을지 혹시 해당 부분은 실무에서 사용하실때 어떤 형태로 하시는지 문의드립니다.구글 검색을 하다보니 AOP로 트랜잭션 new로 한다는 이야기가 있는데 실무에서 어떻게 쓰셨는지 궁금해서 문의드립니다!감사합니다! @Component public class RedissonLockFacade { private RedissonClient redissonClient; private StockService stockService; public RedissonLockFacade(RedissonClient redissonClient, StockService stockService) { this.redissonClient = redissonClient; this.stockService = stockService; } public void decrease(Long id, Long quantity) { RLock lock = redissonClient.getLock(id.toString()); try { boolean available = lock.tryLock(10, 1, TimeUnit.SECONDS); if (!available) { System.out.println("lock 획득 실패"); return; } stockService.decrease(id, quantity); } catch (InterruptedException e) { throw new RuntimeException(e); } finally { lock.unlock(); } } }

- 학습 관련 질문을 남겨주세요. 상세히 작성하면 더 좋아요! - 먼저 유사한 질문이 있었는지 검색해보세요. - 서로 예의를 지키며 존중하는 문화를 만들어가요. - 잠깐! 인프런 서비스 운영 관련 문의는 1:1 문의하기를 이용해주세요. python :select linter를 입력해도 값이 나오지 않습니다. 왜그럴가요?

안녕하십니까 lettuce 라이브러리를 사용해서 lock을 할 때 redisLockRepository.lock(key)로 redis에 key값을 확인 하잖아요 동시에 여러서버에서 lock을 걸 때 저 코드에서는 동시성 문제가 안생기나요?

안녕하세요 수업을 듣고있는 한 사람입니다 ㅎㅎ 너무 잘 듣고있습니다.수업을 들으면서 궁금한점은 검색과 chat gpt 를 통해서 찾아보고있는데요. 단순 chat gpt 의 결과이지만 코루틴은 주로 I/O 바운드와 고수준 구조화된 네트워크 코드에 사용되며, CPU 바운드 작업에는 적합하지 않을 수 있습니다. CPU 바운드 작업을 비동기적으로 처리하려면 멀티 프로세싱이나 다른 접근 방법을 고려해야 할 수 있습니다. 라고 하더라구요 .혹시 여기에 대해서는 어떻게 생각하시나요 ?

 아래 예제 코드에서 "threadSafeNameGroup.notify" 가 정상적으로 동작하려면, 그룹의 enter와 leave 를 사용해주어야 하는 것이 아닌가? 라는 생각이 들었습니다.왜냐하면 "barrierThreadSafePerson.changeName" 메소드가 async로 작업을 보내기 때문입니다.  그럼에도 정상적으로 동작하는 이유는 barrier 플래그를 설정했기 때문에, 현재 쓰레드를 블락처리 했기 때문에 정상적으로 동작했는 것이 아닌가하는 추측을 하고 있습니다.  왜 enter 와 leave가 사용이 되지 않았는지 궁금합니다.

강의 자료를 받고 있는데 스프링 시큐리티 강의 자료가 받아집니다. 확인 부탁드리겠습니다.

안녕하세요.정말 알찬 강의라 멀티프로세싱 스터디에 정말 좋은 교재가 되고 있습니다. 감사드리구요ThreadPoolExecutor를 사용하여 코딩하는데 질문이 있습니다.현재 저는 주식자동화 매매 관련 코딩 스터디 중인데요. ThreadPoolExecutor를 이용하여 주식주문이 동시에 체결되었을때의 병렬처리에 대하여 스터디 하고 있습니다.. 각기 다른 종목이 동시에 주문체결이 되었다면각각의 종목에 대한 후속처리를 동시성을 적용하여 각각 다른 쓰레드를 할당하여 병렬처리를 하면 되지만. 같은 종목이 약간의 시간차(?) 거의 동시에 연속적인 체결이 된다면 이때는 병렬처리가 아닌 앞 주문에 할당된쓰레드가 종료될때 까지 대기하고 있다가(후속작업이 꼬이지 않도록) 뒤에 체결된 주문을 처리하도록 쓰레드를 할당하는 동기적인 처리가 필요한 경우가 있습니다.이런 경우를 처리하기 위한 별도의 메서드가 있는지요? . 아니면 별도의 코딩을 해야한다면 어떤 방식으로코딩을 해야 하는지 문의드립니다. 감사합니다

중첩 스레드는 어떤 경우에 사용하는지 궁금합니다.그동안 래핑된 스레드 클래스를 써와서 그런건지는 모르겠는데,,, 

병렬성과 동시성은 동시에 실행된다는 내용만 같고 구체적인 처리 방식은 달라보이는데 '병렬성은 동시성의 하위 개념'이다 라는 내용이 이해가 안갑니다.만약 동시성이 여러 일이나 사건이 동시에 발생하거나 진행되는 상태를 말한 개념을 말한거라면 '병렬성은 동시성의 하위 개념'이다 라는 내용이 이해가 가는데강사님께서 설명한 특정한 순서 없이 겹치는 기간에 시작, 실행 및 완료 되는 여러 작업에 관한 동시성에 대한 개념으로 '병렬성은 동시성의 하위 개념'이다 라는 내용을 이해해볼려 하면 이해가 안되는 것같습니다.만약 해당 동시성이 후자라면 어떻게 '병렬성은 동시성의 하위 개념'이 되는지 궁금합니다.

StockRepository 가 아닌 stringRedisTemplate 을 사용하면 어떤 차이점이 있을까요?

StockRepositorypublic interface StockRepository extends JpaRepository<Stock, Long> { @Lock(value = LockModeType.PESSIMISTIC_WRITE) @Query("select s from Stock s where s.id = :id") Stock findByIdWithPessimisticLock(@Param("id") Long id); }StockService@Service @RequiredArgsConstructor public class StockService { private final StockRepository stockRepository; @Transactional public Long decrease(Long id, Long quantity) { Stock stock = stockRepository.findByIdWithPessimisticLock(id); stock.decrease(quantity); stockRepository.saveAndFlush(stock); return stock.getQuantity(); } }StockServiceTest@SpringBootTest class PessimisticLockStockServiceTest { @Autowired private StockService service; @Autowired private StockRepository stockRepository; @BeforeEach public void before() { stockRepository.saveAndFlush(new Stock(1L, 100L)); } @AfterEach public void after() { stockRepository.deleteAll(); } @Test @DisplayName("비관적 락을 사용해 재고 감소 동시성 요청이 완료된다.") void decrease() throws InterruptedException { // given int threadCnt = 100; ExecutorService executorService = Executors.newFixedThreadPool(32); CountDownLatch latch = new CountDownLatch(threadCnt); // when for (int i = 0; i < threadCnt; i++) { executorService.submit(() -> { try { service.decrease(1L, 1L); } finally { latch.countDown(); } }); } latch.await(); // then Stock stock = stockRepository.findById(1L).orElseThrow(); assertThat(stock.getQuantity()).isZero(); } }해당 테스트를 돌리면 실패하고 순차적으로 재고가 감소되지 않고 수정 손실이 발생합니다. 아무리 찾아봐도 코드는 제대로 짠 것 같은데 무엇이 잘못 되었을까요??