一次线程OOM排查看线程使用注意事项

java.lang.OutOfMemoryError: pthread_create (1040KB stack) failed: Try again    at java.lang.Thread.nativeCreate(Native Method)    at java.lang.Thread.start(Thread.java:883)    at java.util.concurrent.ThreadPoolExecutor.addWorker(ThreadPoolExecutor.java:975)    at java.util.concurrent.ThreadPoolExecutor.processWorkerExit(ThreadPoolExecutor.java:1043)    at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1185)    at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:641)    at java.lang.Thread.run(Thread.java:919)

DefaultThreadFactory() {    SecurityManager s = System.getSecurityManager();    group = (s != null)? s.getThreadGroup() :                         Thread.currentThread().getThreadGroup();    namePrefix = "pool-" +                  poolNumber.getAndIncrement() +                 "-thread-";}

private void hookThread() {    DexposedBridge.hookAllConstructors(Thread.class, new XC_MethodHook() {        @Override        protected void afterHookedMethod(MethodHookParam param) throws Throwable {            super.afterHookedMethod(param);            Thread thread = (Thread) param.thisObject;            Class<?> clazz = thread.getClass();            if (clazz != Thread.class) {                Log.d(ThreadMethodHook.TAG, "found class extend Thread:" + clazz);                DexposedBridge.findAndHookMethod(clazz, "run", new ThreadMethodHook());            }            Log.d(ThreadMethodHook.TAG, "Thread: " + thread.getName() + " class:" + thread.getClass() +  " is created.");            Log.d(ThreadMethodHook.TAG, "Thread:" + thread.getName() + "stack:" + Log.getStackTraceString(new Throwable()));        }    });}

//只贴了部分相关代码private static OkHttpClient newClient(Context context){    Dispatcher dispatcher = new Dispatcher(Executors.newSingleThreadScheduledExecutor());    ...    return new OkHttpClient.Builder()            .dispatcher(dispatcher)            ...            .build();}

//只贴了部分代码Observable.create(new Observable.OnSubscribe<Throwable>() {    @Override    public void call(Subscriber<? super Throwable> subscriber) {        subscriber.onNext(t);    }}).subscribeOn(Schedulers.newThread()).subscribe(new Subscriber<Throwable>() {    @Override    public void onCompleted() {        ...    }
    @Override    public void onError(Throwable e) {        ...    }
    @Override    public void onNext(Throwable o) {        ...    }});

 at com.taobao.android.dexposed.DexposedBridge.handleHookedArtMethod(DexposedBridge.java:273)        at me.weishu.epic.art.entry.Entry.onHookObject(Entry.java:69)        at me.weishu.epic.art.entry.Entry.referenceBridge(Entry.java:186)        at com.squareup.okhttp.internal.Util$1.newThread(Util.java:225)        at java.util.concurrent.ThreadPoolExecutor$Worker.<init>(ThreadPoolExecutor.java:631)        at java.util.concurrent.ThreadPoolExecutor.addWorker(ThreadPoolExecutor.java:945)        at java.util.concurrent.ThreadPoolExecutor.execute(ThreadPoolExecutor.java:1388)        at com.squareup.okhttp.Dispatcher.enqueue(Dispatcher.java:110)        at com.squareup.okhttp.Call.enqueue(Call.java:114)        at com.squareup.okhttp.OkHttpClient$1.callEnqueue(OkHttpClient.java:98)        at com.squareup.okhttp.ws.WebSocketCall.enqueue(WebSocketCall.java:109)        at com.facebook.react.packagerconnection.ReconnectingWebSocket.connect(ReconnectingWebSocket.java:80)        at com.facebook.react.packagerconnection.ReconnectingWebSocket.delayedReconnect(ReconnectingWebSocket.java:86)        at com.facebook.react.packagerconnection.ReconnectingWebSocket.access$000(ReconnectingWebSocket.java:35)        at com.facebook.react.packagerconnection.ReconnectingWebSocket$1.run(ReconnectingWebSocket.java:104)

@Overridepublic synchronized void onFailure(IOException t, Response response) {    if (mWebSocket != null) {      abort("Websocket exception", t);    }    if (!mClosed) {      if (mConnectionCallback != null) {        mConnectionCallback.onDisconnected();      }      //1.重连      reconnect();    }}

private void reconnect() {    ...    mHandler.postDelayed(        new Runnable() {            @Override            public void run() {                //2.延迟连接                delayedReconnect();            }        },    RECONNECT_DELAY_MS);}

private synchronized void delayedReconnect() {    // check that we haven't been closed in the meantime    if (!mClosed) {        // 3.连接        connect();    }}

public void connect() {    if (mClosed) {      throw new IllegalStateException("Can't connect closed client");    }    //4.创建OkHttpClient    OkHttpClient httpClient = new OkHttpClient();    httpClient.setConnectTimeout(10, TimeUnit.SECONDS);    httpClient.setWriteTimeout(10, TimeUnit.SECONDS);    httpClient.setReadTimeout(0, TimeUnit.MINUTES); // Disable timeouts for read
    Request request = new Request.Builder().url(mUrl).build();    WebSocketCall call = WebSocketCall.create(httpClient, request);    call.enqueue(this);}