forkjoinpool

0열

1답변

난 그냥 자바 7 RecursiveAction.invokeAll()의 사용을보고, 궁금 : 작업의 스레드의 크기는 무엇입니까? (또는 그것을 결정하는 알고리즘) 많은 작업 (예 : 100 개 작업)이있는 경우 사용해야합니까?

5열

1답변

Akka - 부하 테스트 중, CPU 시간의 20 %에서 forkjoinpool.scan

우리는 akka 응용 프로그램의 부하 테스트 및 확장 작업을 잘 진행하고 있지만 scala.concurrent.forkjoin.ForkJoinPool.scan()이 나타납니다. 시각적으로 20 % 정도의 자체 시간 중 두 번째로 높은 핫스팟입니다. 자체 시간 (CPU) 열에는 그 중 일부만 표시됩니다 (자체 시간 열 값의 1 % 미만). 나는 이것이 블로킹

0열

1답변

스레드 내 Threadsafe?

분자 알고리즘을 시뮬레이션하기 위해 Java로 프로그램을 작성하고 있습니다. 분자 알고리즘은 본질적으로 병행 성을 사용하기 때문에 (화학 물질과 농도를 공급하는 한 필요한만큼 화학 반응을 할 수 있습니다), 동시성을 사용해야합니다. 그러나 최근 그래프 구조에 사용하고있는 패키지가 스레드 안전하지 않다는 것을 알게되었습니다. 각 스레드에 대해 그래프의 Arr

1열

2답변

Java의 1.7 ForkJoinPool에서 Q 크기 제한

우리는 외부 I/O가 필요한 몇 가지 작업을 수행하고 있으며 재귀 적입니다. 이를 위해 이전 ExecutorService에서 ForkJoinPool으로 전환하는 프로토 타입을 작성했습니다. I/O 대기 시간은 스레드의 대부분을 소비하므로 병렬 처리 수준은 코어 수보다 분명합니다. 동기식 네트워크 API 만 있으므로 다른 옵션은 없습니다. 이전 Executo

1열

3답변

Java ExecutorService - scaling

ExecutorService과 그 함수 invokeAll을 사용하여 Java로 프로그램을 작성하려고합니다. 내 질문은 : invokeAll 함수가 동시에 작업을 해결합니까? 내 말은, 두 개의 프로세서가있는 경우 동시에 두 명의 작업자가있을 것입니다. 왜냐하면 나는 그것을 정확하게 조절할 수 없기 때문입니다. 내가 newFixedThreadPool(2) 또

11열

1답변

Scala async 대 Java ForkJoinTask

얼마전에 나는 Scala Async Project을 발견했습니다. 질문 :이 async 블럭에서 매크로 함수가 아닌 일반 함수를 통해 구현할 수없는 것은 무엇인가? 도입의 첫 번째 예에서 살펴 보자는 : import ExecutionContext.Implicits.global import scala.async.Async.{async, await} va

0열

1답변

ForkJoin에서 가장 큰 번호 찾기

블록이 없으면 if delay == 2이 작동하지만 작동하지 않습니다. 여기 ForkJoin의 계산이다 : compute() { if(lastElem - firstElem == 1) return array[firstElem]; if(lastElem - firstElem == 2){ if(array[firstEle

0열

3답변

IOException을 일으키는 수천 개의 이미지 로딩을 멀티 스레드하는 데 문제가 있습니다.

ForkJoinPool을 통해 많은 양의 이미지를로드하는 데 문제가 있습니다. 하이퍼 텍스트로 8 코어 스레드를 사용하여 4 코어 Intel에서 테스트하고 있습니다. 그러나 풀을 4 개로 제한합니다. ImageIO에서 이미지를 찾을 수 없다는 오류가 나타납니다. 내가 1700+ 이상의 이미지를 가지고 모든 이미지는 이상 5메가바이트 등을하는 경우 publi

-1열

1답변

GParsPool.withPool과 GParsPool.withExistingPool의 차이점은 무엇입니까?

GParsPool.withPool과 GParsPool.withExistingPool의 차이점은 무엇입니까? 설명서에 설명 된 내용을 이해하지 못했습니다.

0열

1답변

포크/조인을 FileChannel과 결합하여 파일 복사

최근에 Java 7 FORK/JOIN 프레임 워크와 FileChannel을 사용하여 파일을 복사하는 연습을하고 있습니다. 나는 내 코드, 스레드의 수가 1 인 경우 는, 파일이 정확하게 복사되지만를 실행 import java.io.File; import java.io.FileInputStream; import java.io.FileNotFoundExce