Guava - รายละเอียดการเขียนโปรแกรมแบบขนาน

Guava ให้ส่วนขยายที่มีประโยชน์มากมายสำหรับอนาคตการเขียนโปรแกรม Java Parallel อินเทอร์เฟซหลักของมันคือการฟัง Future และมันขยายไปตามความช่วยเหลือของฟิวเจอร์ส

ListenableFuture ที่สืบทอดมาในอนาคตช่วยให้เราสามารถเพิ่มฟังก์ชั่นการโทรกลับเพื่อส่งคืนค่าเมื่อการดำเนินการเธรดเสร็จสมบูรณ์หรือการดำเนินการวิธีการจะถูกส่งคืนทันที

เพิ่มฟังก์ชั่นการเรียกกลับไปยัง ListenableFuture:

futures.addcallback (ListenableFuture <v>, FutureCallback <v>, Executor)

โดยที่ futureCallback เป็นอินเทอร์เฟซที่มี onsuccess (v) และ onfailure (throwable)

ใช้ดังนี้:

 Futures.addCallback (ฟังได้รับ FUTURE, FutureCallback ใหม่ <Ojuct> () {โมฆะสาธารณะ onsuccess (ผลลัพธ์วัตถุ) {system.out.printf ("onsuccess กับ: %s %n",} void public void); -

ในเวลาเดียวกันฟิวเจอร์สใน Guava ก็มี:

1. แปลง: แปลงค่าส่งคืนของ ListenableFuture
2. Allaslist: การรวมของ ListenableFutures หลายครั้งส่งคืนวัตถุรายการที่ส่งคืนค่าผลตอบแทนในอนาคตหลายค่าเมื่ออนาคตทั้งหมดสำเร็จ หมายเหตุ: เมื่อหนึ่งในอนาคตล้มเหลวหรือยกเลิกมันจะป้อนความล้มเหลวหรือยกเลิก
3. SuccessAslist: คล้ายกับ Allaslist ความแตกต่างเพียงอย่างเดียวคือค่าผลตอบแทนในอนาคตที่ล้มเหลวหรือยกเลิกจะถูกแทนที่ด้วย NULL กระบวนการจะไม่ล้มเหลวหรือยกเลิก
4. ทันที/ทันที/ทันทีที่ได้รับการสนับสนุน: ส่งคืนฟังคำบรรยายที่จะส่งคืนทันที
5. MAKECHECKED: แปลง ListenableFuture เป็น CheckedFuture ตรวจสอบ FUTURE เป็นฟังก์ชั่นการฟังที่มีหลายเวอร์ชันของวิธี GET ซึ่งประกาศว่าจะทำการตรวจสอบข้อยกเว้น สิ่งนี้ทำให้ง่ายต่อการสร้างอนาคตที่สามารถโยนข้อยกเว้นในตรรกะการดำเนินการ
6. jdkfutureadapters.listeninpoolthread (อนาคต): Guava ยังมีฟังก์ชั่นอินเทอร์เฟซเพื่อแปลง JDK Future เป็น ListenableFuture
   

ด้านล่างนี้เป็นตัวอย่างการทดสอบสำหรับอนาคต:

 @TestPublic โมฆะควร _Test_Furture () โยนข้อยกเว้น {ListenexecutorService Service = Moreexecutors.listeningDecorator (Executors.NewFixedThreadPool (10)); ListenableFuture Future1 = service.submit (ใหม่ callable <integer> () {การโทรจำนวนเต็มสาธารณะ () พ่น InterruptedException {thread.sleep (1000); System.out.println ("โทรอนาคต 1"); return 1;}}); ListenableFuture Future2 = service.submit (ใหม่ callable <teger> () {การโทรจำนวนเต็มสาธารณะ () พ่น InterruptedException {thread.sleep (1000); System.out.println ("โทรอนาคต 2"); // โยน runtimeException ใหม่ ( Final ListenableFuture AllFuture = Futures.Allaslist (Future1, Future2); Final ListenableFuture transform = futures.Transform (allfutures, ใหม่ asyncFunction <list <integer>, boolean> () {@Override สาธารณะฟังการใช้งาน (รายการ <treger> ผลลัพธ์) โยนข้อยกเว้น futures.addcallback (แปลง, futureCallback ใหม่ <jobch> () {โมฆะสาธารณะ onsuccess (ผลลัพธ์วัตถุ) {system.out.println (result.getClass ()); System.out.printf ("ความสำเร็จด้วย:%s%n",} thrown.getMessage ());}}); System.out.println (transform.get ());}

หน้าแรกข้อมูลอย่างเป็นทางการ: https://awk.so/@code.google.com!/p/guava-libraries/wiki/listenablefutureexplained

ข้างต้นคือข้อมูลที่แยกแยะอนาคตของ Guava - การเขียนโปรแกรมแบบขนาน เราจะยังคงเพิ่มข้อมูลที่เกี่ยวข้องในอนาคต ขอบคุณสำหรับการสนับสนุนเว็บไซต์นี้!