MongoDB WriteConcern Java 드라이버

Question

나는 단순한 mongo 응용 프로그램을 비동기 적으로 사용합니다 (Akka 사용). 액터로 메시지를 보내면 액터가 데이터베이스에 3 개의 레코드를 씁니다. 필자는 WriteConcern.SAFE를 사용하고 있습니다. 쓰기가 발생했는지 확인하기 (WriteConcern.FSYNC_SAFE도 시도했기 때문입니다).

잠시 멈추고 쓰기가 발생하면 읽기가 수행되고 아무 것도 얻지 못합니다.

그래서 내 쓰기 코드는 다음과 같을 수 있습니다 : 다음

collection.save(myObj, WriteConcern.SAFE) 
println("--1--") 
collection.save(myObj, WriteConcern.SAFE) 
println("--2--") 
collection.save(myObj, WriteConcern.SAFE) 
println("--3--") 

내 테스트 코드에서 (배우 외부 실행 - 다른 스레드에서) 내가 레코드의 #을 인쇄 내가 찾을 :

println(collection.findAll(...)) 

내 출력은 다음과 같습니다.

--1-- 
--2-- 
--3-- 
(pauses) 
0 

실제로 데이터베이스를 보면 기록이 없습니다. 가끔은 실제로 거기에 데이터를 볼 수 및 테스트 작동합니다. 비동기 코드는 까다로울 수 있으며 쓰기가 발생하기 전에 테스트 코드가 히트 될 가능성이 있으므로 타임 스탬프를 인쇄하여 표시된 순서대로 실행되도록 노력했습니다. 데이터가 있어야합니다. 타임 스탬프/w 아래의 샘플 출력 :

Saved: brand_1/dev 1375486024040 
Saved: brand_1/dev2 1375486024156 
Saved: brand_1/dev3 1375486024261 
         1375486026593 0 found 

그래서 3은 읽기가 시도 된 전체 이초 전에 분명히 무슨 일이 있었 세이브 (및 작성해야).

나는이 행동을 취할 수있는보다 자유로운 WriteConcerns에 대해 이해하지만 가장 안전한 두 사람은 진행하기 전에 실제로 기록이 남았음을 확신 할 것이라고 생각했습니다.

Answer 1

미묘하지만 단순한 문제. 내 연결을 만들 때 데프 (def)를 사용하고 있었는데, 그 다음 발을 마치 두 번 호출하기 시작했습니다. 그래서 실제로 두 명의 작가가 있었기 때문에 내 결과의 차이점을 설명했습니다. 발에 리팩토링되어 모든 것이 예측 가능했습니다. 식별하기 쉽고, 이해하기 쉽고/고치기 쉽습니다.