您可以編寫自己的ThreadFactory

ThreadFactory custom = new CustomThreadFactory();

ExecutorService executorService = Executors.newCachedThreadPool(custom); //or use newSingleThreadExecutor(..)

Scheduler customScheduler = Schedulers.from(executorService); 現在

你可以使用這個調度，并需要一個新的線程時不阻塞主隊列以及獲取調用：

class CustomThreadFactory implements ThreadFactory {

public Thread lastT;

public int newThreadCounter = 0;

@Override

public Thread newThread(Runnable r) {

newThreadCounter++;

System.out.println("newThread called");

Thread lastT = new Thread(r); //or CustomThread(r)

return lastT;

}

}

，你甚至可以去進一步和儀器新線程 -

class CustomThread extends Thread {

public CustomThread(Runnable r) {

super(r);

}

@Override

public void run() {

System.out.printf("About to run!");

super.run();

}

}

}

總結

以上是生活随笔為你收集整理的android 单元测试 多线程,单元测试多线程Android RxJava的全部內容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網站內容還不錯，歡迎將生活随笔推薦給好友。