您可以編寫自己的ThreadFactory

ThreadFactory custom = new CustomThreadFactory();

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

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

你可以使用這個(gè)調(diào)度，并需要一個(gè)新的線程時(shí)不阻塞主隊(duì)列以及獲取調(diào)用：

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;

}

}

，你甚至可以去進(jìn)一步和儀器新線程 -

class CustomThread extends Thread {

public CustomThread(Runnable r) {

super(r);

}

@Override

public void run() {

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

super.run();

}

}

}

總結(jié)

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

如果覺得生活随笔網(wǎng)站內(nèi)容還不錯(cuò)，歡迎將生活随笔推薦給好友。