1
구체적으로 어떻게 처리해야할지 모르겠습니까? 기본적으로 나는 내 기억을 넘어 많은 데이터를 생성하는 프로그램을 가지고있다. (예를 들어, 10 기가의 데이터와 4 기가의 램이있다.) 나는 데이터를 가져 와서 디스크에 쓰는 쓰레드를 포크하기로 결정했다. 비록 디스크 쓰기가 그것을 생성하는 프로세스를 따라 잡을 수 없다는 것을 알았지 만, 애플리케이션을 디스크에 얼마나 빨리 쓸 수 있을지를 바랄 수 있었다. 하지만 잠시 후에 나는 힙 메모리 부족 오류가 발생합니다. 내가 생각대기열에 저장된 큰 데이터를 파일에 쓰는 중 메모리 오류가 발생했습니다.
다음의 부품과 관련된 :
static class SaveToFile extends Thread {
public void run() {
FileWriter bw = null;
try {
bw = new FileWriter("output.csv");
Thread.sleep(500); //delay the start so the queue can have some data
} catch (IOException e1) {
// TODO Auto-generated catch block
e1.printStackTrace();
} catch (InterruptedException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
System.out.println("size of results during execution is " + result.size());
while(!result.isEmpty()) {
short[] current = result.poll();
try {
bw.write(Arrays.toString(current) + "," + "\n");
} catch (IOException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
}
try {
bw.flush();
bw.close();
} catch (IOException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
System.out.println("file writing is done");
}
}
아니에요 : 여기
private static Queue<short[]> result = new LinkedList <short[]>();
내 아이디어는 SaveToFile 스레드가 대기열을 지우면 다른 프로세스가 계속 쓰기 위해 여유 공간을 확보한다는 것입니다 (이것들은 주 프로그램과 SaveToFile을 실행하는 유일한 스레드입니다).
메모리가 가득 차면 같은 효과가있을 것이라고 생각했습니다. 더 많은 공간이 생길 때까지 쓰는 것을 멈출 수 있습니까? –
@ Error_404 : 아니, 그렇게하지 않습니다. – NPE
고마워, 나는 LinkedList..sorry를 차단하고 동기화하는 방법을 배우게 될 것이다. 그러나 고통을 느끼는 것은 왜 잠금이 필요한가?내가 목록의 끝 (result.add (data ...);)을 작성하고 앞에서 폴링하면 잠금의 이점은 무엇입니까? –