Zincirleme iş

WorkManager, birden fazla bağımlı görevi belirten ve bunların hangi sırayla çalıştırılması gerektiğini tanımlayan bir çalışma zinciri oluşturup sıraya eklemenize olanak tanır. Bu işlev, özellikle birkaç görevi belirli bir sırayla çalıştırmanız gerektiğinde kullanışlıdır.

İş zinciri oluşturmak için her biri WorkContinuation örneği döndüren WorkManager.beginWith(OneTimeWorkRequest) veya WorkManager.beginWith(List<OneTimeWorkRequest>) yöntemini kullanabilirsiniz.

Ardından, then(OneTimeWorkRequest) veya then(List<OneTimeWorkRequest>) kullanarak bağımlı OneTimeWorkRequest örnekleri eklemek için bir WorkContinuation kullanılabilir.

WorkContinuation.then(...) her çağrıldığında WorkContinuation'ün yeni bir örneği döndürülür. OneTimeWorkRequest örnekten oluşan bir List eklerseniz bu istekler paralel olarak çalıştırılabilir.

Son olarak, WorkContinuation enqueue() için WorkContinuation.enqueue() yöntemini kullanabilirsiniz.

Bunu bir örnek üzerinden inceleyelim. Bu örnekte, 3 farklı Worker işi çalıştırılacak şekilde yapılandırılmıştır (potansiyel olarak paralel). Bu çalışanların sonuçları daha sonra birleştirilir ve önbelleğe alma çalışan işine aktarılır. Son olarak, bu işin çıkışı, sonuçları uzak bir sunucuya yükleyen bir yükleme Worker'ına iletilir.

Kotlin

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()

Java

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();

Giriş Birleştiriciler

OneTimeWorkRequest örneklerini zincirlediğinizde üst iş isteklerinin çıkışı, alt iş isteklerine giriş olarak iletilir. Yukarıdaki örnekte plantName1, plantName2 ve plantName3 çıkışları, cache isteğine giriş olarak iletilir.

WorkManager, birden fazla üst iş isteğinden gelen girişleri yönetmek için InputMerger kullanır.

WorkManager tarafından sağlanan iki farklı InputMerger türü vardır:

  • OverwritingInputMerger tüm girişlerdeki tüm anahtarları çıkışa eklemeye çalışır. Çakışma durumunda, daha önce ayarlanmış anahtarların üzerine yazılır.

  • ArrayCreatingInputMerger girişleri birleştirmeye çalışır ve gerektiğinde diziler oluşturur.

Daha spesifik bir kullanım alanınız varsa InputMerger alt sınıfını oluşturarak kendi sınıfınızı yazabilirsiniz.

OverwritingInputMerger

OverwritingInputMerger, varsayılan birleştirme yöntemidir. Birleştirme işleminde anahtar çakışmaları varsa bir anahtarın en son değeri, sonuçta elde edilen çıkış verilerindeki önceki sürümlerin üzerine yazılır.

Örneğin, tesis girişlerinin her birinde ilgili değişken adlarıyla ("plantName1", "plantName2" ve "plantName3") eşleşen bir anahtar varsa cache çalışanına iletilen verilerde üç anahtar/değer çifti bulunur.

Zincirdeki bir sonraki işe farklı çıkışlar ileten üç işi gösteren diyagram. Üç çıkışın da farklı anahtarları olduğundan sonraki iş üç anahtar/değer çifti alır.

Çakışma varsa tamamlanan son çalışan "kazanır" ve değeri cache değerine iletilir.

Zincirdeki bir sonraki işe çıkışları ileten üç işi gösteren diyagram. Bu durumda, bu işlerden ikisi aynı anahtara sahip çıkışlar üretir. Sonuç olarak, bir sonraki iş iki anahtar/değer çifti alır ve çakışan çıkışlardan biri bırakılır.

İş istekleriniz paralel olarak çalıştırıldığından, çalışma sırası garanti edilmez. Yukarıdaki örnekte plantName1, en son yazılan değere bağlı olarak "tulip" veya "elm" değerini alabilir. Anahtar çakışması olasılığı varsa ve birleştirme işleminde tüm çıkış verilerini korumanız gerekiyorsa ArrayCreatingInputMerger daha iyi bir seçenek olabilir.

ArrayCreatingInputMerger

Yukarıdaki örnekte, tüm bitki adı çalışanlarının çıkışlarını korumak istediğimiz için ArrayCreatingInputMerger kullanmamız gerekir.

Kotlin

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

Java

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

ArrayCreatingInputMerger, her anahtarı bir diziyle eşleştirir. Anahtarların her biri benzersizse sonucunuz tek öğeli dizilerden oluşan bir seri olur.

Zincirdeki bir sonraki işe farklı çıkışlar ileten üç işi gösteren diyagram. Sonraki işe, her bir çıkış anahtarı için bir tane olmak üzere üç dizi iletilir. Her dizinin tek bir üyesi vardır.

Anahtar çakışmaları varsa ilgili değerler bir dizide gruplandırılır.

Zincirdeki bir sonraki işe çıkışları ileten üç işi gösteren diyagram. Bu durumda, bu işlerden ikisi aynı anahtara sahip çıkışlar üretir. Bir sonraki işe her anahtar için bir tane olmak üzere iki dizi iletilir. Bu dizilerden birinde, bu anahtara sahip iki çıkış olduğu için iki üye vardır.

Zincirleme ve Çalışma Durumları

OneTimeWorkRequest zincirleri, işleri başarıyla tamamlandığı (yani Result.success() döndürdüğü) sürece sırayla yürütülür. İş istekleri, çalışırken başarısız olabilir veya iptal edilebilir. Bu durum, bağımlı iş isteklerini de etkiler.

Bir iş isteği zincirinde ilk OneTimeWorkRequest sıraya alındığında, bu ilk iş isteğinin işi tamamlanana kadar sonraki tüm iş istekleri engellenir.

Bir iş zincirini gösteren diyagram. İlk iş sıraya alınır. İlk iş tamamlanana kadar sonraki tüm işler engellenir.

Sıraya alındıktan ve tüm iş kısıtlamaları karşılandıktan sonra ilk iş isteği çalışmaya başlar. Kök OneTimeWorkRequest veya List<OneTimeWorkRequest> içinde iş başarıyla tamamlanırsa (yani Result.success() döndürürse) bir sonraki bağımlı iş istekleri sıraya alınır.

Bir iş zincirini gösteren diyagram. İlk iş başarılı oldu ve hemen ardından gelen iki iş sıraya alındı. Kalan işler, önceki işleri tamamlanana kadar engellenir.

Her iş isteği başarıyla tamamlandığı sürece bu model, zincirdeki tüm işler tamamlanana kadar iş istekleri zincirinizin geri kalanında yayılır. Bu en basit ve genellikle tercih edilen durum olsa da hata durumlarını ele almak da bir o kadar önemlidir.

Bir çalışan, iş isteğinizi işlerken hata oluşursa tanımladığınız geri çekilme politikasına göre bu isteği yeniden deneyebilirsiniz. Bir zincirin parçası olan isteği yeniden denemek, yalnızca o isteğin kendisine sağlanan giriş verileriyle yeniden deneneceği anlamına gelir. Paralel olarak çalışan işler etkilenmez.

Bir iş zincirini gösteren diyagram. İşlerden biri başarısız oldu ancak tanımlanmış bir geri çekilme politikası vardı. Bu iş, uygun bir süre geçtikten sonra yeniden çalıştırılır. Zincirde bu işten sonra gelen işler, bu iş başarıyla çalıştırılana kadar engellenir.

Özel yeniden deneme stratejileri tanımlama hakkında daha fazla bilgi için Yeniden Deneme ve Geri Çekilme Politikası'na bakın.

Bu yeniden deneme politikası tanımlanmamışsa veya tükenmişse ya da OneTimeWorkRequest öğesinin Result.failure() döndürdüğü bir duruma ulaşırsanız bu iş isteği ve tüm bağımlı iş istekleri FAILED. olarak işaretlenir.

Bir iş zincirini gösteren diyagram. Bir iş başarısız oldu ve tekrar denenemez. Sonuç olarak, zincirde ondan sonraki tüm işler de başarısız olur.

Aynı mantık, OneTimeWorkRequest iptal edildiğinde de geçerlidir. Bağımlı iş istekleri de CANCELLED olarak işaretlenir ve bu isteklerin işleri yürütülmez.

Bir iş zincirini gösteren diyagram. Bir iş iptal edildi. Bunun sonucunda, zincirde bu işten sonraki tüm işler de iptal edilir.

Başarısız olan veya iptal edilen iş istekleri içeren bir zincire daha fazla iş isteği eklerseniz yeni eklenen iş isteğiniz de sırasıyla FAILED veya CANCELLED olarak işaretlenir. Mevcut bir zincirin çalışmasını genişletmek istiyorsanız ExistingWorkPolicy bölümündeki APPEND_OR_REPLACE konusuna bakın.

İş isteği zincirleri oluştururken bağımlı iş istekleri, işin her zaman zamanında tamamlanmasını sağlamak için yeniden deneme politikaları tanımlamalıdır. Başarısız iş istekleri, eksik zincirlere ve/veya beklenmedik durumlara neden olabilir.

Daha fazla bilgi için Çalışmayı İptal Etme ve Durdurma başlıklı makaleyi inceleyin.