Revert "Check whether an AsyncTask is created/executed on a looper thread."

import java.util.concurrent.atomic.AtomicInteger;

import java.util.concurrent.atomic.AtomicInteger;

/**

/**

 * <p>AsyncTask enables proper and easy use of the UI thread (also called main thread) or

 * <p>AsyncTask enables proper and easy use of the UI thread. This class allows to

 * any other looper thread. AsyncTask is most commonly used to interact with the UI thread.

 * perform background operations and publish results on the UI thread without

 * This class allows to perform background operations and publish results on a looper

 * having to manipulate threads and/or handlers.</p>

 * thread without having to manipulate threads and/or handlers.</p>

 *

 *

 * <p>An asynchronous task is defined by a computation that runs on a background thread and

 * <p>An asynchronous task is defined by a computation that runs on a background thread and

 * whose result is published on a looper thread. An asynchronous task is defined by 3 generic

 * whose result is published on the UI thread. An asynchronous task is defined by 3 generic

 * types, called <code>Params</code>, <code>Progress</code> and <code>Result</code>,

 * types, called <code>Params</code>, <code>Progress</code> and <code>Result</code>,

 * and 4 steps, called <code>onPreExecute</code>, <code>doInBackground</code>,

 * and 4 steps, called <code>onPreExecute</code>, <code>doInBackground</code>,

 * <code>onProgressUpdate</code> and <code>onPostExecute</code>.</p>

 * <code>onProgressUpdate</code> and <code>onPostExecute</code>.</p>

 * <h2>The 4 steps</h2>

 * <h2>The 4 steps</h2>

 * <p>When an asynchronous task is executed, the task goes through 4 steps:</p>

 * <p>When an asynchronous task is executed, the task goes through 4 steps:</p>

 * <ol>

 * <ol>

 *     <li>{@link #onPreExecute()}, invoked on the looper thread immediately after the task

 *     <li>{@link #onPreExecute()}, invoked on the UI thread immediately after the task

 *     is executed. This step is normally used to setup the task, for instance by

 *     is executed. This step is normally used to setup the task, for instance by

 *     showing a progress bar in the user interface.</li>

 *     showing a progress bar in the user interface.</li>

 *     <li>{@link #doInBackground}, invoked on the background thread

 *     <li>{@link #doInBackground}, invoked on the background thread

 *     of the asynchronous task are passed to this step. The result of the computation must

 *     of the asynchronous task are passed to this step. The result of the computation must

 *     be returned by this step and will be passed back to the last step. This step

 *     be returned by this step and will be passed back to the last step. This step

 *     can also use {@link #publishProgress} to publish one or more units

 *     can also use {@link #publishProgress} to publish one or more units

 *     of progress. These values are published on the looper thread, in the

 *     of progress. These values are published on the UI thread, in the

 *     {@link #onProgressUpdate} step.</li>

 *     {@link #onProgressUpdate} step.</li>

 *     <li>{@link #onProgressUpdate}, invoked on the looper thread after a

 *     <li>{@link #onProgressUpdate}, invoked on the UI thread after a

 *     call to {@link #publishProgress}. The timing of the execution is

 *     call to {@link #publishProgress}. The timing of the execution is

 *     undefined. This method is used to display any form of progress in the user

 *     undefined. This method is used to display any form of progress in the user

 *     interface while the background computation is still executing. For instance,

 *     interface while the background computation is still executing. For instance,

 *     it can be used to animate a progress bar or show logs in a text field.</li>

 *     it can be used to animate a progress bar or show logs in a text field.</li>

 *     <li>{@link #onPostExecute}, invoked on the looper thread after the background

 *     <li>{@link #onPostExecute}, invoked on the UI thread after the background

 *     computation finishes. The result of the background computation is passed to

 *     computation finishes. The result of the background computation is passed to

 *     this step as a parameter.</li>

 *     this step as a parameter.</li>

 * </ol>

 * </ol>

 * <p>There are a few threading rules that must be followed for this class to

 * <p>There are a few threading rules that must be followed for this class to

 * work properly:</p>

 * work properly:</p>

 * <ul>

 * <ul>

 *     <li>The task instance must be created on the looper thread.</li>

 *     <li>The task instance must be created on the UI thread.</li>

 *     <li>{@link #execute} must be invoked on the looper thread.</li>

 *     <li>{@link #execute} must be invoked on the UI thread.</li>

 *     <li>Do not call {@link #onPreExecute()}, {@link #onPostExecute},

 *     <li>Do not call {@link #onPreExecute()}, {@link #onPostExecute},

 *     {@link #doInBackground}, {@link #onProgressUpdate} manually.</li>

 *     {@link #doInBackground}, {@link #onProgressUpdate} manually.</li>

 *     <li>The task can be executed only once (an exception will be thrown if

 *     <li>The task can be executed only once (an exception will be thrown if

 *     <li>Set member fields in {@link #doInBackground}, and refer to them in

 *     <li>Set member fields in {@link #doInBackground}, and refer to them in

 *     {@link #onProgressUpdate} and {@link #onPostExecute}.

 *     {@link #onProgressUpdate} and {@link #onPostExecute}.

 * </ul>

 * </ul>

 * 

 * @see Looper

 * @see Handler

 */

 */

public abstract class AsyncTask<Params, Progress, Result> {

public abstract class AsyncTask<Params, Progress, Result> {

    private static final String LOG_TAG = "AsyncTask";

    private static final String LOG_TAG = "AsyncTask";

    private static final int MESSAGE_POST_RESULT = 0x1;

    private static final int MESSAGE_POST_RESULT = 0x1;

    private static final int MESSAGE_POST_PROGRESS = 0x2;

    private static final int MESSAGE_POST_PROGRESS = 0x2;

    private static final ThreadLocal<InternalHandler> sHandler =

    private static final InternalHandler sHandler = new InternalHandler();

            new ThreadLocal<InternalHandler>() {

                @Override

                protected InternalHandler initialValue() {

                    return new InternalHandler();

                }

            };

    private static volatile Executor sDefaultExecutor = SERIAL_EXECUTOR;

    private static volatile Executor sDefaultExecutor = SERIAL_EXECUTOR;

    private final WorkerRunnable<Params, Result> mWorker;

    private final WorkerRunnable<Params, Result> mWorker;

    private volatile Status mStatus = Status.PENDING;

    private volatile Status mStatus = Status.PENDING;

    private final AtomicBoolean mTaskInvoked = new AtomicBoolean();

    private final AtomicBoolean mTaskInvoked = new AtomicBoolean();

    private final InternalHandler mHandler;

    private static class SerialExecutor implements Executor {

    private static class SerialExecutor implements Executor {

        final ArrayDeque<Runnable> mTasks = new ArrayDeque<Runnable>();

        final ArrayDeque<Runnable> mTasks = new ArrayDeque<Runnable>();

        FINISHED,

        FINISHED,

    }

    }

    /** @hide */

    /** @hide Used to force static handler to be created. */

    public static void init() {

    public static void init() {

        sHandler.getLooper();

    }

    }

    /** @hide */

    /** @hide */

    }

    }

    /**

    /**

     * Creates a new asynchronous task. This constructor must be invoked on the looper thread.

     * Creates a new asynchronous task. This constructor must be invoked on the UI thread.

     * 

     * @throws IllegalStateException if this constructor is invoked on a non-looper thread

     * 

     * @see Looper

     */

     */

    public AsyncTask() {

    public AsyncTask() {

        if (Looper.myLooper() == null) {

            throw new IllegalStateException("AsyncTask can be only instanciated on a " 

                    + "looper thread. The current thread is " + Thread.currentThread());

        }

        mHandler = sHandler.get();

        mWorker = new WorkerRunnable<Params, Result>() {

        mWorker = new WorkerRunnable<Params, Result>() {

            public Result call() throws Exception {

            public Result call() throws Exception {

                mTaskInvoked.set(true);

                mTaskInvoked.set(true);

    }

    }

    private Result postResult(Result result) {

    private Result postResult(Result result) {

<<<<<<< HEAD

        Message message = sHandler.obtainMessage(MESSAGE_POST_RESULT,

        Message message = sHandler.obtainMessage(MESSAGE_POST_RESULT,

=======

        @SuppressWarnings({"unchecked"})

        Message message = mHandler.obtainMessage(MESSAGE_POST_RESULT,

>>>>>>> 6c0d0b8... Check whether an AsyncTask is created/executed on a looper thread.

                new AsyncTaskResult<Result>(this, result));

                new AsyncTaskResult<Result>(this, result));

        message.sendToTarget();

        message.sendToTarget();

        return result;

        return result;

     * by the caller of this task.

     * by the caller of this task.

     *

     *

     * This method can call {@link #publishProgress} to publish updates

     * This method can call {@link #publishProgress} to publish updates

     * on the looper thread.

     * on the UI thread.

     *

     *

     * @param params The parameters of the task.

     * @param params The parameters of the task.

     *

     *

    protected abstract Result doInBackground(Params... params);

    protected abstract Result doInBackground(Params... params);

    /**

    /**

     * Runs on the looper thread before {@link #doInBackground}.

     * Runs on the UI thread before {@link #doInBackground}.

     *

     *

     * @see #onPostExecute

     * @see #onPostExecute

     * @see #doInBackground

     * @see #doInBackground

    }

    }

    /**

    /**

     * <p>Runs on the looper thread after {@link #doInBackground}. The

     * <p>Runs on the UI thread after {@link #doInBackground}. The

     * specified result is the value returned by {@link #doInBackground}.</p>

     * specified result is the value returned by {@link #doInBackground}.</p>

     * 

     * 

     * <p>This method won't be invoked if the task was cancelled.</p>

     * <p>This method won't be invoked if the task was cancelled.</p>

    }

    }

    /**

    /**

     * Runs on the looper thread after {@link #publishProgress} is invoked.

     * Runs on the UI thread after {@link #publishProgress} is invoked.

     * The specified values are the values passed to {@link #publishProgress}.

     * The specified values are the values passed to {@link #publishProgress}.

     *

     *

     * @param values The values indicating progress.

     * @param values The values indicating progress.

    }

    }

    /**

    /**

     * <p>Runs on the looper thread after {@link #cancel(boolean)} is invoked and

     * <p>Runs on the UI thread after {@link #cancel(boolean)} is invoked and

     * {@link #doInBackground(Object[])} has finished.</p>

     * {@link #doInBackground(Object[])} has finished.</p>

     * 

     * 

     * <p>The default implementation simply invokes {@link #onCancelled()} and

     * <p>The default implementation simply invokes {@link #onCancelled()} and

     * This method is invoked by the default implementation of

     * This method is invoked by the default implementation of

     * {@link #onCancelled(Object)}.</p>

     * {@link #onCancelled(Object)}.</p>

     * 

     * 

     * <p>Runs on the looper thread after {@link #cancel(boolean)} is invoked and

     * <p>Runs on the UI thread after {@link #cancel(boolean)} is invoked and

     * {@link #doInBackground(Object[])} has finished.</p>

     * {@link #doInBackground(Object[])} has finished.</p>

     *

     *

     * @see #onCancelled(Object) 

     * @see #onCancelled(Object) 

     * an attempt to stop the task.</p>

     * an attempt to stop the task.</p>

     * 

     * 

     * <p>Calling this method will result in {@link #onCancelled(Object)} being

     * <p>Calling this method will result in {@link #onCancelled(Object)} being

     * invoked on the looper thread after {@link #doInBackground(Object[])}

     * invoked on the UI thread after {@link #doInBackground(Object[])}

     * returns. Calling this method guarantees that {@link #onPostExecute(Object)}

     * returns. Calling this method guarantees that {@link #onPostExecute(Object)}

     * is never invoked. After invoking this method, you should check the

     * is never invoked. After invoking this method, you should check the

     * value returned by {@link #isCancelled()} periodically from

     * value returned by {@link #isCancelled()} periodically from

     * with {@link #THREAD_POOL_EXECUTOR}; however, see commentary there for warnings on

     * with {@link #THREAD_POOL_EXECUTOR}; however, see commentary there for warnings on

     * its use.

     * its use.

     *

     *

     * <p>This method must be invoked on the looper thread.

     * <p>This method must be invoked on the UI thread.

     *

     *

     * @param params The parameters of the task.

     * @param params The parameters of the task.

     *

     *

     * @return This instance of AsyncTask.

     * @return This instance of AsyncTask.

     *

     *

     * @throws IllegalStateException If {@link #getStatus()} returns either

     * @throws IllegalStateException If {@link #getStatus()} returns either

     *         {@link AsyncTask.Status#RUNNING} or {@link AsyncTask.Status#FINISHED} or

     *         {@link AsyncTask.Status#RUNNING} or {@link AsyncTask.Status#FINISHED}.

     *         the current thread is not a looper thread.

     */

     */

    public final AsyncTask<Params, Progress, Result> execute(Params... params) {

    public final AsyncTask<Params, Progress, Result> execute(Params... params) {

        return executeOnExecutor(sDefaultExecutor, params);

        return executeOnExecutor(sDefaultExecutor, params);

     * executed in serial; to guarantee such work is serialized regardless of

     * executed in serial; to guarantee such work is serialized regardless of

     * platform version you can use this function with {@link #SERIAL_EXECUTOR}.

     * platform version you can use this function with {@link #SERIAL_EXECUTOR}.

     *

     *

     * <p>This method must be invoked on the looper thread.

     * <p>This method must be invoked on the UI thread.

     *

     *

     * @param exec The executor to use.  {@link #THREAD_POOL_EXECUTOR} is available as a

     * @param exec The executor to use.  {@link #THREAD_POOL_EXECUTOR} is available as a

     *              convenient process-wide thread pool for tasks that are loosely coupled.

     *              convenient process-wide thread pool for tasks that are loosely coupled.

     * @return This instance of AsyncTask.

     * @return This instance of AsyncTask.

     *

     *

     * @throws IllegalStateException If {@link #getStatus()} returns either

     * @throws IllegalStateException If {@link #getStatus()} returns either

     *         {@link AsyncTask.Status#RUNNING} or {@link AsyncTask.Status#FINISHED} or

     *         {@link AsyncTask.Status#RUNNING} or {@link AsyncTask.Status#FINISHED}.

     *         the current thread is not a looper thread.

     */

     */

    public final AsyncTask<Params, Progress, Result> executeOnExecutor(Executor exec,

    public final AsyncTask<Params, Progress, Result> executeOnExecutor(Executor exec,

            Params... params) {

            Params... params) {

        if (Looper.myLooper() == null) {

            throw new IllegalStateException("AsyncTask can be only instanciated on a " 

                    + "looper thread. The current thread is " + Thread.currentThread());

        }

        if (mStatus != Status.PENDING) {

        if (mStatus != Status.PENDING) {

            switch (mStatus) {

            switch (mStatus) {

                case RUNNING:

                case RUNNING:

    /**

    /**

     * This method can be invoked from {@link #doInBackground} to

     * This method can be invoked from {@link #doInBackground} to

     * publish updates on the looper thread while the background computation is

     * publish updates on the UI thread while the background computation is

     * still running. Each call to this method will trigger the execution of

     * still running. Each call to this method will trigger the execution of

     * {@link #onProgressUpdate} on the looper thread.

     * {@link #onProgressUpdate} on the UI thread.

     *

     *

     * {@link #onProgressUpdate} will note be called if the task has been

     * {@link #onProgressUpdate} will note be called if the task has been

     * canceled.

     * canceled.

     */

     */

    protected final void publishProgress(Progress... values) {

    protected final void publishProgress(Progress... values) {

        if (!isCancelled()) {

        if (!isCancelled()) {

            mHandler.obtainMessage(MESSAGE_POST_PROGRESS,

            sHandler.obtainMessage(MESSAGE_POST_PROGRESS,

                    new AsyncTaskResult<Progress>(this, values)).sendToTarget();

                    new AsyncTaskResult<Progress>(this, values)).sendToTarget();

        }

        }

    }

    }