concurrency

0열

1답변

폐쇄는 scala.concurrent.Future에 대한 루프에서 두 번째로 다음과 같은 <code>Future</code>을 만드는 두 번째를 호출

나는 두 가지 방법이 문제가 발생하고있어, 처음 예상대로 작동하지 : public class WorkersCoordinator { private static Logger LOGGER = LoggerFactory.getLogger(WorkersCoordinator.class); private final Timeout timeou

0열

1답변

어떻게 병렬 또는 동시 API 호출을 할 수 있습니까?

Android 앱 (실제로는 첫 번째 앱)을 제작 중이며 검색 한 것과 유사한 트랙이 표시됩니다. 내 호출에 대해 rxJava 및 gson과 함께 retrofit2를 사용하고 있습니다. 각 트랙마다 이미지 뷰에서 응답으로 제공된 해당 이미지를 추가했지만 실제 이미지가 아니므로 밴드의 이미지 일뿐입니다. 앨범 검색을 할 경우 API에서 얻을 수있는 앨범 이미

1열

1답변

`lazy_static` 내부에서`evmap`을 사용할 수 있습니까?

Rust 프로그램의 모든 스레드에서 잠금없이 결과적으로 일관성있는 동시 다중 값 맵 evmap을 공유하고 싶습니다. 순진, 그 결과는 다음과 같습니다 #[macro_use] extern crate lazy_static; extern crate evmap; use std::collections::hash_map::RandomState; lazy_

2열

2답변

자바의 Ada 랑데뷰 대응 자

Ada 프로그래밍 언어에서 랑데부는 프로세스 간 동기화/메시지 전달 방법입니다. Java에서이 메커니즘을 구현하려면 어떻게해야합니까 (태스크 일시 중단 및 선택 대기와 함께)? java의 원격 메서드 호출과 Exchanger 클래스를 살펴 보았지만 적절한 솔루션을 아직 찾지 못했습니다. ADA하지만은 당신이 가능 SynchronousQueue의 Blocki

0열

1답변

Java 디스플레이 출력을 열/행

현재 출력하고있는 것 대신에 출력을 표시하려고하고 있습니다. 계정 "계정 1을": 나는 그것이 어느 정도 같이 할 0 (1) (16) (16), 1 (0) 12 12, 2 (2) 0 0 \ t를 구분 기호와 printf로 사용해 보았지만 알아 내지 못했습니다. 코드가 제대로 포맷 사과 경우, 나는 아직도 내가 어떤 도움이나 조언 import java.uti

2열

1답변

많은 executor를 사용할 때 Ideal/best 스레드 풀 크기는 무엇입니까?

많은 게시물에서 CPU + 1의 수에 따라 최대 풀 크기에 대한 수식을 읽을 수 있습니다. 명확한 설명입니다. 그러나 응용 프로그램에 많은 Executor 또는 ThreadPoolExecutor가 정의되어 있으면 어떻게됩니까? 그런 다음 응용 프로그램이 동일한 하드웨어를 공유하는 것으로 간주해야합니다. 이것이 풀 크기 선택에 미치는 영향. 크기를 전역으로

0열

2답변

LinkedBlockingQueue에서 elments를 제거하는 동안 아래 코드가 안전합니까?

나는 라이브 소켓을 얻기 위해 동시에 여러 스레드에 의해 호출되는 아래 메소드를 가지고있다. 매개 변수로 LinkedBlockingQueue을 취한 다음 사용 가능한 liveSocket이 있는지 반복하고 볼 수 있습니다. 사용 가능한 경우 소켓을 제거한 다음 반환합니다. private Optional<Holder> getSocket(final LinkedB

1열

1답변

Go 동기화 맵의 동시 처리 문제

Go의 sync.Map에 문제가 있습니다. 아래는 세부 사항은 다음과 같습니다 내가 좋아하는 글로벌 싱크 맵을 생성 : var MySyncGlobalMap = sync.Map{} 및 이벤트에 나는 map[int64]map[string]interface{}으로 의도 된 구조로이지도를 채 웁니다. 그래서 기본적으로 동기화 맵 을 int64 키로 설정하고 또

0열

2답변

일정 시간 동안 goroutine에서 값 받기

무한 수의 값을 생성 할 수있는 goroutine이 있지만 각 값을 찾기 위해 점점 길어집니다. 시간 제한을 추가하는 방법을 찾으려고합니다. 예를 들어 10 초가 지나면 지금까지받은 함수 중에서 가장 좋은 값을 가진 함수가 실행됩니다. 이것은 채널과 타이머를 사용하여 내 현재 "솔루션"입니다 : // the goroutine which runs infini

2열

2답변

비동기/기다리고 있습니다 작동하지 않습니다

안녕하세요 내 컨트롤러에이 코드가 있습니다 [HttpGet] [Route("/Test")] public async Task<IActionResult> Test() { Console.WriteLine("foo"); await Task.Delay(2000); Console.WriteLine("bar"); return Ok