ฉันกำลังโทรในชั้นบริการ Java ที่มีลักษณะเช่นนี้
Future<Object> future = Patterns.ask(myActor, message, timeout);
Response res = (Response) Await.result(future, timeout.duration());
ฉันได้อ่านเอกสารของ Akka แล้วและพบว่าไม่แนะนำให้บล็อกเช่นนี้ ฉันต้องส่งคืนออบเจ็กต์ตอบกลับไปยังวิธีการโทร เป็นไปได้ไหมที่ทำสิ่งนี้แบบอะซิงโครนัสกับ Akka จากบริการ Java ของฉัน ฉันพยายามทำสิ่งนี้โดยใช้วิธี future.onSuccess แต่วิธี onSuccess ไม่อนุญาตให้ส่งคืนค่า ดังนั้นฉันจึงไม่สามารถคืนค่าได้
วิธี Akka ในการส่งข้อมูลระหว่างเธรด ซึ่งโดยพื้นฐานแล้วสิ่งที่คุณทำโดยการบล็อกด้านบนคือการสร้างอนาคตหรือส่งข้อความถึงนักแสดง
ตัวอย่างต่อไปนี้นำมาจากเอกสารประกอบของ Akka
final ExecutionContext ec = system.dispatcher();
Future<String> f1 = future(new Callable<String>() {
public String call() {
return "Hello" + "World";
}
}, ec);
Future<Integer> f2 = f1.map(new Mapper<String, Integer>() {
public Integer apply(String s) {
return s.length();
}
}, ec);
f2.onSuccess(new PrintResult<Integer>(), system.dispatcher());
โปรดสังเกตว่าในตัวอย่างนี้ข้อมูลกำลัง 'ส่งคืน' หรือถ้าให้เจาะจงกว่านั้นคือกำลังถูกส่งไปยังหน่วยงานอื่นโดยที่เธรดไม่ต้องบล็อกและรอผลลัพธ์
นี่คือสาเหตุที่ onSuccess ส่งกลับเป็นโมฆะ มันจะถูกใช้ที่จุดสิ้นสุดของห่วงโซ่แห่งอนาคตที่แต่งขึ้น หากจะคืนค่าก็จะเป็นเหมือนแผนที่และจะส่งกลับอนาคตอื่น ซึ่งจะทำให้คุณมีข้อกำหนดในการบล็อกเหมือนกัน
ดังนั้นเพื่อตอบคำถามของคุณไม่ใช่ ไม่มีทางที่จะ 'ส่งคืน' ค่าจากอนาคตแบบอะซิงโครนัสโดยไม่ปิดกั้น แต่คุณควรตรวจสอบว่าทำไมคุณจึงต้องการให้การตอบกลับเป็นเช่นนั้น และดูว่าคุณสามารถย้ายการจัดการการตอบกลับไปที่ onSuccess หรือแผนที่แทนได้หรือไม่ ทางเลือกรองคือการส่งคืน Future[Response] และปล่อยให้ผู้โทรกังวลเกี่ยวกับการผูกมัดอนาคต กรณีที่คุณประสบมักจะเกิดขึ้นเมื่อผสมกระบวนทัศน์ และควรหลีกเลี่ยงอย่างดีที่สุด
