งานเชน

WorkManager ช่วยให้คุณสร้างและจัดคิวงานแบบเป็นลําดับซึ่งระบุงานที่ต้องพึ่งพาหลายรายการและกำหนดลำดับที่ควรทำงาน ฟังก์ชันการทำงานนี้จะมีประโยชน์อย่างยิ่งเมื่อคุณต้องเรียกใช้งานหลายรายการตามลําดับที่เจาะจง

หากต้องการสร้างเชนงาน คุณสามารถใช้ WorkManager.beginWith(OneTimeWorkRequest) หรือ WorkManager.beginWith(List<OneTimeWorkRequest>) ซึ่งแต่ละรายการจะแสดงอินสแตนซ์ของ WorkContinuation

จากนั้นจะใช้ WorkContinuation เพื่อเพิ่มอินสแตนซ์ OneTimeWorkRequest ที่เกี่ยวข้องได้โดยใช้ then(OneTimeWorkRequest) หรือ then(List<OneTimeWorkRequest>)

การเรียกใช้ WorkContinuation.then(...) ทุกครั้งจะแสดงผลอินสแตนซ์ WorkContinuation ใหม่ หากคุณเพิ่มอินสแตนซ์ List ของ OneTimeWorkRequest คำขอเหล่านี้อาจทํางานพร้อมกันได้

สุดท้าย คุณสามารถใช้วิธี WorkContinuation.enqueue() เพื่อenqueue()WorkContinuation หลายรายการ

มาดูตัวอย่างกัน ในตัวอย่างนี้ มีการกำหนดค่างาน Worker 3 รายการให้ทำงาน (อาจทำงานพร้อมกัน) จากนั้นระบบจะรวมผลลัพธ์ของโหนดเหล่านี้และส่งต่อไปยังงานโหนดแคช สุดท้าย ระบบจะส่งเอาต์พุตของงานนั้นไปยังเวิร์กเกอร์การอัปโหลด ซึ่งจะอัปโหลดผลลัพธ์ไปยังเซิร์ฟเวอร์ระยะไกล

WorkManager.getInstance(myContext)
   // Candidates to run in parallel
   .beginWith(listOf(plantName1, plantName2, plantName3))
   // Dependent work (only runs after all previous work in chain)
   .then(cache)
   .then(upload)
   // Call enqueue to kick things off
   .enqueue()

WorkManager.getInstance(myContext)
   // Candidates to run in parallel
   .beginWith(Arrays.asList(plantName1, plantName2, plantName3))
   // Dependent work (only runs after all previous work in chain)
   .then(cache)
   .then(upload)
   // Call enqueue to kick things off
   .enqueue();

อินพุตการผสาน

เมื่อคุณต่อเชนอินสแตนซ์ OneTimeWorkRequest ระบบจะส่งเอาต์พุตของคำของานหลักเป็นอินพุตไปยังอินสแตนซ์ย่อย ดังนั้นในตัวอย่างข้างต้น ระบบจะส่งเอาต์พุตของ plantName1, plantName2 และ plantName3 เป็นอินพุตไปยังคำขอ cache

WorkManager ใช้ InputMerger เพื่อจัดการอินพุตจากคำของานหลักหลายรายการ

InputMerger ที่ WorkManager มีให้มีอยู่ 2 ประเภท ดังนี้

• OverwritingInputMerger พยายามเพิ่มคีย์ทั้งหมดจากอินพุตทั้งหมดไปยังเอาต์พุต ในกรณีที่มีความขัดแย้ง ระบบจะเขียนทับคีย์ที่ตั้งไว้ก่อนหน้านี้

• ArrayCreatingInputMerger จะพยายามผสานอินพุตเพื่อสร้างอาร์เรย์เมื่อจำเป็น

หากมี Use Case ที่เฉพาะเจาะจงมากขึ้น คุณสามารถเขียนเองได้โดยการสร้างคลาสย่อยจาก InputMerger

OverwritingInputMerger

OverwritingInputMerger เป็นวิธีการผสานเริ่มต้น หากมีคีย์ทับซ้อนกันในการผสาน ระบบจะเขียนทับค่าล่าสุดของคีย์นั้นในข้อมูลเอาต์พุตที่ได้

ตัวอย่างเช่น หากอินพุตของพืชแต่ละรายการมีคีย์ที่ตรงกับชื่อตัวแปรที่เกี่ยวข้อง ("plantName1", "plantName2" และ "plantName3") ข้อมูลที่จะส่งไปยังผู้ปฏิบัติงาน cache จะมีคู่คีย์-ค่า 3 คู่

หากมีความขัดแย้ง เวิร์กเกอร์คนสุดท้ายที่ดำเนินการเสร็จสมบูรณ์จะ "ชนะ" และค่าของเวิร์กเกอร์คนดังกล่าวจะส่งไปยัง cache

เนื่องจากคำขอทำงานจะดำเนินการควบคู่กัน คุณจึงไม่สามารถรับประกันลำดับการเรียกใช้ได้ ในตัวอย่างข้างต้น plantName1 อาจมีค่าเป็น "tulip" หรือ "elm" ทั้งนี้ขึ้นอยู่กับว่าค่าใดเขียนไว้เป็นค่าสุดท้าย หากมีความเสี่ยงที่จะเกิดข้อขัดแย้งของคีย์และจำเป็นต้องเก็บรักษาข้อมูลเอาต์พุตทั้งหมดในการผสาน ArrayCreatingInputMerger อาจเป็นตัวเลือกที่ดีกว่า

การผสานอินพุตของอาร์เรย์ที่สร้าง

สําหรับตัวอย่างข้างต้น เนื่องจากเราต้องการเก็บรักษาเอาต์พุตจากเวิร์กเกอร์ที่มีชื่อ plant ทั้งหมด เราจึงควรใช้ ArrayCreatingInputMerger

val cache: OneTimeWorkRequest = OneTimeWorkRequestBuilder<PlantWorker>()
   .setInputMerger(ArrayCreatingInputMerger::class)
   .setConstraints(constraints)
   .build()

OneTimeWorkRequest cache = new OneTimeWorkRequest.Builder(PlantWorker.class)
       .setInputMerger(ArrayCreatingInputMerger.class)
       .setConstraints(constraints)
       .build();

ArrayCreatingInputMerger จะจับคู่คีย์แต่ละรายการกับอาร์เรย์ หากแต่ละคีย์ไม่ซ้ำกัน ผลลัพธ์จะเป็นชุดอาร์เรย์ 1 องค์ประกอบ

หากมีคีย์ที่ทับซ้อนกัน ระบบจะจัดกลุ่มค่าที่เกี่ยวข้องไว้ในอาร์เรย์

สถานะการต่อและสถานะการทํางาน

OneTimeWorkRequest หลายรายการจะทํางานตามลําดับตราบใดที่งานเสร็จสมบูรณ์ (นั่นคือ แสดงผลเป็น Result.success()) คําของานอาจดำเนินการไม่สำเร็จหรือถูกยกเลิกขณะทำงาน ซึ่งส่งผลต่อคำของานที่เกี่ยวข้องในลำดับถัดไป

เมื่อ OneTimeWorkRequest แรกอยู่ในคิวของเชนคำของาน ระบบจะบล็อกคำของานที่ตามมาทั้งหมดจนกว่างานของคำของานแรกนั้นจะเสร็จสมบูรณ์

เมื่อจัดคิวและข้อจำกัดในการทำงานทั้งหมดแล้ว คำของานแรกจะเริ่มต้นทำงาน หากงานเสร็จสมบูรณ์ในรูท OneTimeWorkRequest หรือ List<OneTimeWorkRequest> (นั่นคือ ระบบแสดงผล Result.success()) ระบบจะจัดคิวคําของานแบบขึ้นต่อกันชุดถัดไป

ตราบใดที่คำของานแต่ละรายการดำเนินการสำเร็จ รูปแบบเดียวกันนี้ก็จะเผยแพร่ผ่านคำของานที่เหลือในเชนของคุณจนกว่างานทั้งหมดในเชนจะเสร็จสิ้น แม้ว่านี่จะเป็นกรณีที่ง่ายที่สุดและมักเลือกใช้กัน แต่สถานะข้อผิดพลาดก็เป็นสิ่งสำคัญที่ต้องจัดการเช่นกัน

เมื่อเกิดข้อผิดพลาดขณะที่ผู้ปฏิบัติงานดำเนินการตามคำของาน คุณจะลองส่งคำขอนั้นอีกครั้งได้ตามนโยบาย Backoff ที่คุณกำหนด การลองใช้คำขอที่เป็นส่วนหนึ่งของเชนอีกครั้งหมายความว่าระบบจะลองดำเนินการกับคำขอนั้นอีกครั้งโดยใช้ข้อมูลอินพุตที่ให้ไว้ งานที่กำลังทำงานอยู่พร้อมกันจะไม่ได้รับผลกระทบ

ดูข้อมูลเพิ่มเติมเกี่ยวกับการกําหนดกลยุทธ์การลองใหม่ที่กำหนดเองได้ที่นโยบายการลองใหม่และเวลาพัก

หากนโยบายการลองอีกครั้งนั้นไม่มีการกำหนดหรือหมดแล้ว หรือคุณไปถึงสถานะที่ OneTimeWorkRequest แสดงผลเป็น Result.failure() ระบบจะทำเครื่องหมายคำของานนั้นและคำของานที่เกี่ยวข้องทั้งหมดเป็น FAILED.

หลักการเดียวกันนี้ยังใช้กับการยกเลิก OneTimeWorkRequest ด้วย คําของานที่เกี่ยวข้องทั้งหมดจะมีเครื่องหมาย CANCELLED ด้วย และระบบจะไม่ดําเนินการกับงานดังกล่าว

โปรดทราบว่าหากคุณจะส่งคำของานเพิ่มเติมไปยังเชนที่ดำเนินการไม่สำเร็จหรือยกเลิกคำของานไปแล้ว คำของานที่เพิ่งเพิ่มเข้ามาใหม่จะมีเครื่องหมายเป็น FAILED หรือ CANCELLED ตามลำดับด้วย หากต้องการขยายเวลาทำงานของเชนที่มีอยู่ โปรดดู APPEND_OR_REPLACE ใน ExistingWorkPolicy

เมื่อสร้างห่วงโซ่ของคำของาน คำของานที่ต้องทำงานที่ต้องพึ่งพากันควรกำหนดนโยบายลองอีกครั้งเพื่อให้งานเสร็จตรงเวลาเสมอ คำของานที่ไม่สำเร็จอาจส่งผลให้เกิดเชนที่ไม่สมบูรณ์และ/หรือสถานะที่ไม่คาดคิด

ดูข้อมูลเพิ่มเติมได้ที่การยกเลิกและหยุดการทำงาน