AsyncBuilder { @NonNull @VisibleForTesting @UiThread BlockingQueue<Runnable> getWorkerQueue() { Log.v(TAG, "getWorkerQueue()"); if (workerQueue == null) { Log.d(TAG, "Creating default worker queue"); setWorkerQueue(new LinkedBlockingDeque<>()); } return workerQueue; } @UiThread  AsyncBuilder(@NonNull Context context); @UiThread boolean isRuntimeAssertionsEnabled(); @UiThread AsyncBuilder setRuntimeAssertionsEnabled(boolean enabled); @UiThread boolean isUseForkedState(); @UiThread AsyncBuilder setUseForkedState(boolean enabled); @UiThread boolean isStrictMode(); @UiThread AsyncBuilder setStrictMode(boolean enabled); @UiThread boolean isFailFast(); @NonNull @UiThread AsyncBuilder setFailFast(boolean failFast); @UiThread boolean isShowErrorStackTraces(); @NonNull @UiThread AsyncBuilder setShowErrorStackTraces(boolean showErrorStackTraces); @NonNull @UiThread AsyncBuilder setWorkerThreadType(@NonNull IThreadType workerThreadType); @NonNull @UiThread AsyncBuilder setSerialWorkerThreadType(@NonNull final IThreadType serialWorkerThreadType); @NonNull @UiThread AsyncBuilder setUIThreadType(@NonNull IThreadType uiThreadType); @NonNull @UiThread AsyncBuilder setNetReadThreadType(@NonNull IThreadType netReadThreadType); @NonNull @UiThread AsyncBuilder setNetWriteThreadType(@NonNull IThreadType netWriteThreadType); @NonNull @UiThread AsyncBuilder setFileThreadType(@NonNull IThreadType fileThreadType); @NonNull @UiThread AsyncBuilder setWorkerQueue(@NonNull final BlockingQueue<Runnable> queue); @NonNull @UiThread AsyncBuilder setSerialWorkerQueue(@NonNull final BlockingQueue<Runnable> queue); @NonNull @UiThread AsyncBuilder setFileQueue(@NonNull BlockingQueue<Runnable> queue); @NonNull @UiThread AsyncBuilder setNetReadQueue(@NonNull BlockingQueue<Runnable> queue); @NonNull @UiThread AsyncBuilder setNetWriteQueue(@NonNull BlockingQueue<Runnable> queue); @NonNull @UiThread AsyncBuilder setUiExecutorService(@NonNull ExecutorService uiExecutorService); @NonNull @UiThread AsyncBuilder setWorkerExecutorService(@NonNull ExecutorService executorService); @NonNull @UiThread AsyncBuilder setSerialWorkerExecutorService(@NonNull ExecutorService executorService); @NonNull @UiThread AsyncBuilder singleThreadedWorkerExecutorService(); @NonNull @UiThread AsyncBuilder setFileExecutorService(@NonNull ExecutorService fileExecutorService); @NonNull @UiThread AsyncBuilder setNetReadExecutorService(@NonNull ExecutorService netReadExecutorService); @NonNull @UiThread AsyncBuilder setNetWriteExecutorService(@NonNull ExecutorService netWriteExecutorService); @NonNull @UiThread AsyncBuilder setUiThread(@NonNull Thread uiThread); @NonNull @NotCallOrigin @UiThread Async build(); static final int NUMBER_OF_CORES; static final int NUMBER_OF_CONCURRENT_NET_READS; @NonNull
    final Context context; public Thread uiThread; public ExecutorService uiExecutorService; }
@Test public void testGetWorkerQueue() throws Exception { asyncBuilder .setWorkerQueue(queue) .build(); assertEquals(queue, asyncBuilder.getWorkerQueue()); }