larksuite-oapi/src/main/java/com/larksuite/oapi/okhttp3_14/RealCall.java
void executeOn(ExecutorService executorService) {
      assert (!Thread.holdsLock(client.dispatcher()));
      boolean success = false;
      try {
        executorService.execute(this);
        success = true;
      } catch (RejectedExecutionException e) {
        InterruptedIOException ioException = new InterruptedIOException("executor rejected");
        ioException.initCause(e);
        transmitter.noMoreExchanges(ioException);
        responseCallback.onFailure(RealCall.this, ioException);
      } finally {
        if (!success) {
          client.dispatcher().finished(this); // This call is no longer running!
        }
      }
    }
/**
     * Attempt to enqueue this async call on {@code executorService}. This will attempt to clean up
     * if the executor has been shut down by reporting the call as failed.
     */
Attempt to enqueue this async call on  executorService. This will attempt to clean up
if the executor has been shut down by reporting the call as failed.
Attempt to enqueue this async call on executorService . This will attempt to clean up if the executor has been shut down by reporting the call as failed .
void executeOn(ExecutorService executorService) {
      assert (!Thread.holdsLock(client.dispatcher()));
      boolean success = false;
      try {
        executorService.execute(this);
        success = true;
      } catch (RejectedExecutionException e) {
        InterruptedIOException ioException = new InterruptedIOException("executor rejected");
        ioException.initCause(e);
        transmitter.noMoreExchanges(ioException);
        responseCallback.onFailure(RealCall.this, ioException);
      } finally {
        if (!success) {
          client.dispatcher().finished(this); 
        }
      }
    }
void executeOn ( ExecutorService executorService ) { assert ( ! Thread . holdsLock ( client . dispatcher ( ) ) ) ; boolean success = false ; try { executorService . execute ( this ) ; success = true ; } catch ( RejectedExecutionException e ) { InterruptedIOException ioException = new InterruptedIOException ( "executor rejected" ) ; ioException . initCause ( e ) ; transmitter . noMoreExchanges ( ioException ) ; responseCallback . onFailure ( RealCall . this , ioException ) ; } finally { if ( ! success ) { client . dispatcher ( ) . finished ( this ) ; } } }
Attempt to enqueue this async call on {@code executorService}.
Attempt to enqueue this async call on { @code executorService } .
// This call is no longer running!