SubmissionPublisher 類別

定義

[Android.Runtime.Register("java/util/concurrent/SubmissionPublisher", ApiSince=33, DoNotGenerateAcw=true)]
[Java.Interop.JavaTypeParameters(new System.String[] { "T" })]
public class SubmissionPublisher : Java.Lang.Object, IDisposable, Java.Lang.IAutoCloseable, Java.Util.Concurrent.Flow.IPublisher

[<Android.Runtime.Register("java/util/concurrent/SubmissionPublisher", ApiSince=33, DoNotGenerateAcw=true)>]
[<Java.Interop.JavaTypeParameters(new System.String[] { "T" })>]
type SubmissionPublisher = class
    inherit Object
    interface IAutoCloseable
    interface IJavaObject
    interface IDisposable
    interface IJavaPeerable
    interface Flow.IPublisher

繼承

Object

JavaObject

Object

SubmissionPublisher

屬性

RegisterAttribute JavaTypeParametersAttribute

實作

IJavaObject IJavaPeerable IAutoCloseable Flow.IPublisher IDisposable

備註

一個 Flow.Publisher 非同步地將提交的（非空）項目發送給現有訂閱者，直到訂閱結束。 每位現有訂閱者都會以相同順序收到新提交的商品，除非遇到掉落或例外情況。 使用 SubmissionPublisher 讓項目產生器能作為合規 的反應式串流 ，依賴 drop 處理和/或阻擋來控制流量。

SubmissionPublisher 利用其建構器中提供的資訊 Executor 來傳遞給訂閱者。 執行者的最佳選擇取決於預期使用情況。 如果提交項目的產生器在獨立執行緒中運行，且訂閱者數量可以估計，請考慮使用 。Executors#newFixedThreadPool 否則請考慮使用預設值，通常是 ForkJoinPool#commonPool。

緩衝讓生產者與消費者能暫時以不同速率運作。 每個用戶使用獨立的緩衝區。 緩衝區會在首次使用時建立，並根據需要擴展至指定最大值。 （強制容量可向上取整至最接近的二的冪次方，和/或以此實作支持的最大值為界。）調用 的 Flow.Subscription#request(long) request 呼叫不會直接導致緩衝區擴充，但若未填滿的請求超過最大容量，則有飽和的風險。 預設值 可 Flow#defaultBufferSize() 作為根據預期速率、資源及使用量選擇容量的有用起點。

單一 SubmissionPublisher 可能在多個來源間共享。 在發布項目或發出 i<happen-before>/i< 訊號>前，來源執行緒中每個訂閱者在相應存取後的動作。 但報告的延遲與需求估計是用於監控，而非同步控制，且可能反映陳舊或不準確的進展觀點。

發表方法支持不同政策，說明緩衝區飽和時應採取的措施。 方法 #submit(Object) submit 區塊直到資源可用。 這是最簡單，但反應最慢的。 這些 offer 方法可能會立即丟棄項目（或有界逾時），但提供介入處理程序並重試的機會。

若任何訂閱者方法拋出例外，該訂閱即被取消。 若以建構子參數形式提供處理器，則在方法中異常Flow.Subscriber#onNext onNext時，該處理器會在取消前被呼叫，但方法Flow.Subscriber#onSubscribe onSubscribeFlow.Subscriber#onError(Throwable) onErrorFlow.Subscriber#onComplete() onComplete中的異常在刪除前不會被記錄或處理。 若所提供的執行器在執行任務時拋 RejectedExecutionException 出（或其他任何 RuntimeException 或錯誤），或丟棄處理程序在處理丟棄項目時拋出異常，則該例外會被重新拋出。 在這些情況下，並非所有訂閱者都已獲得已發佈的項目。 在這種情況下，通常 #closeExceptionally closeExceptionally 這樣做是很好的做法。

此方法 #consume(Consumer) 簡化了一種常見情境的支援，即訂閱者唯一的操作是使用所提供的函式請求並處理所有項目。

此類別亦可作為子類別產生項目的便利基礎，並利用該類別的方法發佈。 舉例來說，這裡有一個類別會定期發布供應商產生的項目。 （實務上，你可以加入獨立啟動與停止生成的方法，在出版者間共享執行者等，或將 SubmissionPublisher 作為元件而非超類別。）

{@code
            class PeriodicPublisher<T> extends SubmissionPublisher<T> {
              final ScheduledFuture<?> periodicTask;
              final ScheduledExecutorService scheduler;
              PeriodicPublisher(Executor executor, int maxBufferCapacity,
                                Supplier<? extends T> supplier,
                                long period, TimeUnit unit) {
                super(executor, maxBufferCapacity);
                scheduler = new ScheduledThreadPoolExecutor(1);
                periodicTask = scheduler.scheduleAtFixedRate(
                  () -> submit(supplier.get()), 0, period, unit);
              }
              public void close() {
                periodicTask.cancel(false);
                scheduler.shutdown();
                super.close();
              }
            }}

這裡有一個實作範例 Flow.Processor 。 它採用單步請求給出版商，以簡化說明。 較適應性的版本則可利用從 submit回傳的延遲估計值監控流量，並結合其他實用性方法。

{@code
            class TransformProcessor<S,T> extends SubmissionPublisher<T>
              implements Flow.Processor<S,T> {
              final Function<? super S, ? extends T> function;
              Flow.Subscription subscription;
              TransformProcessor(Executor executor, int maxBufferCapacity,
                                 Function<? super S, ? extends T> function) {
                super(executor, maxBufferCapacity);
                this.function = function;
              }
              public void onSubscribe(Flow.Subscription subscription) {
                (this.subscription = subscription).request(1);
              }
              public void onNext(S item) {
                subscription.request(1);
                submit(function.apply(item));
              }
              public void onError(Throwable ex) { closeExceptionally(ex); }
              public void onComplete() { close(); }
            }}

新增9。

Java 文件 java.util.concurrent.SubmissionPublisher。

本頁部分內容為基於 Open Source Project 所創建與分享的作品，並依授權條款所描述的使用進行修改。