concurrency

    1

    2답변

    내가이 같은 기능을 가지고 가정 : 이제 import scala.concurrent._ def plus2Future(fut: Future[Int]) (implicit ec: ExecutionContext): Future[Int] = fut.map(_ + 2) 내가 만들 plus2Future를 사용하여 오전 Future 새로운 : imp

    1

    1답변

    큰 데이터 문제로 작업 중이며 일부 동시성 및 비동기 문제에 봉착했습니다. 이 문제는 다음과 같다 : 1) 여러 큰 파일 (내가 concurrent.futures 모듈에서 ProcessPoolExecutor이 방법으로 사용하여 처리하고 ~ 4기가바이트 15 개까지 각 x)의 유무 : def process(source): files = os.list

    -1

    1답변

    정기적으로 쿠폰 코드를 사이트에서 긁어내어 유효성을 검사하고 알림을 보내야합니다. 유효성 검사가 느려지므로 그 프로세스가 내 응용 프로그램의 흐름을 망칠 수 있기를 원하지 않습니다. 이상적으로, 스크레이퍼는 더 많은 결과를 끌어 내기 위해 유효성 검사가 끝날 때까지 기다릴 필요가 없습니다. 는이 같은 찾고 데이터 흐름을 상상 : SCRAPER --> \_/

    0

    1답변

    내가지도에 선택된 특정 위치에 대한 정보를 얻을 아래와 같은 방법 getLabelFromServer를 호출하여 내 응용 프로그램의 UI에 표시 할 Retrofit2를 사용 을 업데이트 UI 마지막 API 호출에 따라 있도록 여러 개조 호출을 관리하고 취소 할 수 있습니다. 사용자 이후 내가 서버로부터 정보를 수신하기 위해 기다리고있는 동안, 내가받은 정보를

    1

    1답변

    업데이트 : 한마디로 , 내가 서비스에 대한 사용자의 메시지를 보내는 큐가 있습니다. 그러나 하나의 서비스가 1000s의 메시지를 받으면 큐보다 이 우세합니다. 큐가 비게 될 때까지 다른 서비스는 메시지를받지 못합니다. 이 접근 방법에 대한 해결책이 필요합니다. BlockingQueue 's에 문제가 있습니다. 내가 그들에게 메시지를 전달할 책임이있는 10

    0

    1답변

    일부 데이터 프로세서를 만드는 중입니다. 그것은 다음 API 메소드를 가지고 있습니다 : 어떤 태스크를 생성하고, 태스크 결과를 얻습니다. 데이터 프로세서가 실패한 경우 복구해야하며 여러 인스턴스에서 실행할 수 있어야합니다. (DP1, DP2 등). 상태를 Redis db에 저장합니다. 예 : API는 작업 (Runnable)을 만들고 scheduledTh

    0

    1답변

    저는 Goroutine으로 함수를 호출하고 WaitGroup을 사용하여 공유 스캐너가 모두 종료되기 전에 닫는 것을 방지합니다. myfunc() 함수는 파일을 반복 실행합니다. 필자는이 파일을 메모리 맵핑하고 매번 디스크에서 읽는 것의 I/O 문제가 아니라 모든 goroutine 사이에서 공유하려고했습니다. 이 접근 방식이 작동 할 것이라고 나는 들었다.

    0

    1답변

    고속/고용량 동시성 제어 상황에서 사용되는 스핀 록, 세마포어, 원자 변수, 순환 버퍼, KIFIFO 및 RCU를 사용할 수 있습니까? 이 자료는 더 많은 것을 이해하기 위해 장치 드라이버에 포함되어 있습니다.

    0

    2답변

    저는 ThreadPool과 ExecutorService를 사용하여 1에서 9까지의 숫자를 세는 간단한 프로그램을 가지고 있습니다. 각 스레드는 1 초 동안 실행을 기다리고 있습니다. 그러나 아래의 프로그램은 각 실행마다 임의의 결과를 제공합니다. 나는이 문제를 해결하는 방법을 잘 모르겠습니다 항상 45 어떤 도움을주십시오을 생산! public static

    1

    1답변

    IIS 7에서 C# 웹 서비스를 호스팅 할 예정입니다.이 응용 프로그램의 트래픽은 약간 거대하고 분당 100 건의 요청 일 수 있습니다. IIS가 동시에 얼마나 많은 요청을 처리 할 수 ​​있습니까? 감사합니다.