Executando tarefas sequencialmente em outra Thread no Android

 Este post exemplifica uma necessidade que às vezes ocorre em um projeto: executar uma série de tarefas sequencialmente em uma thread.
 Para fazer isso temos um recurso em Java que atende perfeitamente ao requisito acima: a estrutura Executor. Um executor é basicamente um gerenciador de threads e tarefas.
 O exemplo consiste em executar uma série de tarefas numa única thread que é controlada por um executor. A tarefa vai ser representada por uma classe que vai implementar um Runnable (MyTask). Para não ficar invisível vamos atualizar a tela com o Dialog.
 Vamos também usar uma outra thread para definir o Executor e submeter as tarefas para execução e aguardar até o fim de todas as tarefas para encerrar o Dialog ( MyControlThread).

 Os códigos:
 TesteExecutorsActivity.java package br.com.agorandroid.testeexecutors; import android.app.Activity; import android.os.Bundle; import java.util.concurrent.ExecutorService; import java.util.concurrent.Executors; import android.app.ProgressDialog; import android.os.Handler; import android.view.View; import android.view.View.OnClickListener; import android.widget.Button; import android.widget.Toast; public class TesteExecutorsActivity extends Activity { Button button; MyControlThread mThread; ProgressDialog mDialog; Handler mHandler; int LIMITE = 10; /** Called when the activity is first created. */ @Override public void onCreate(Bundle savedInstanceState) { super.onCreate(savedInstanceState); setContentView(R.layout.main); button = (Button) findViewById(R.id.iniciarthread); button.setOnClickListener(new OnClickListener() { public void onClick(View v) { ativaThread(); } }); } private void ativaThread() { mDialog = ProgressDialog.show(this, "Aguarde", "Processando...", false, false); mHandler = new Handler(); mThread = new MyControlThread(LIMITE); mThread.start(); } private class MyControlThread extends Thread { private int numTasks; public MyControlThread(int tasks) { this.numTasks = tasks; } @Override public void run() { ExecutorService executor = Executors.newSingleThreadExecutor(); for (int i = 1; i <= numTasks; i++) { Runnable worker = new MyTask("task" +i, 5); executor.submit(worker); } executor.shutdown(); while (!executor.isTerminated()) { try { Thread.sleep(1000); } catch (InterruptedException e) { } } mHandler.post(new Runnable() { @Override public void run() { mDialog.dismiss(); } }); } } private class MyTask implements Runnable { private int numLoops; private String nome; public MyTask(String nome, int loops) { this.nome = nome; numLoops = loops; } public void run() { mHandler.post(new Runnable() { @Override public void run() { mDialog.setMessage("Processando " + nome); } }); fazerAlgoDemorado(); mHandler.post(new Runnable() { @Override public void run() { Toast.makeText(TesteExecutorsActivity.this, "Fim da " + nome, Toast.LENGTH_SHORT).show(); } }); } private void fazerAlgoDemorado() { int i = 0; do { try { Thread.sleep(1000); i++; } catch (InterruptedException e) { } } while (i<numLoops); } } }


main.xml
<?xml version="1.0" encoding="utf-8"?> <linearlayout xmlns:android="http://schemas.android.com/apk/res/android" android:orientation="vertical" android:layout_width="fill_parent" android:layout_height="fill_parent" > <textview android:layout_width="fill_parent" android:layout_height="wrap_content" android:text="@string/hello" /> <button android:text="Iniciar Thread" android:id="@+id/iniciarthread" android:layout_width="fill_parent" android:layout_height="wrap_content"> </Button> </LinearLayout>


Manifest file
<?xml version="1.0" encoding="utf-8"?> <manifest xmlns:android="http://schemas.android.com/apk/res/android" package="br.com.agorandroid.testeexecutor" android:versionCode="1" android:versionName="1.0" > <uses-sdk android:minSdkVersion="7" /> <application android:icon="@drawable/ic_launcher" android:label="@string/app_name" > <activity android:name=".TesteExecutorActivity" android:label="@string/app_name" > <intent-filter> <action android:name="android.intent.action.MAIN" /> <category android:name="android.intent.category.LAUNCHER" /> </intent-filter> </activity> </application> </manifest>

PS: Algumas considerações sobre o código: No trecho abaixo, devemos observar o seguinte:
 a. O executor é definido com uma thread para podermos executar as tarefas sequencialmente uma a uma. ExecutorService executor = Executors.newSingleThreadExecutor(); for (int i = 1; i <= numTasks; i++) { Runnable worker = new MyTask("task" +i, 5); executor.submit(worker); }
b. O loop for é para simular a submissão de "n" tarefas, normalmente teríamos diversas tarefas diferentes sendo submetidas da seguinte forma: Runnable worker1 = new MyTask1("task1"); executor.submit(worker1); Runnable worker2 = new MyTask2("task2"); executor.submit(worker2); . . . Runnable workerN = new MyTaskN("taskN"); executor.submit(workerN);
PS1: Nas tarefas, o Handler é utilizado para executar algum código na UI Thread, normalmente para alterar a tela.

 Executando no emulador:

Thread, Handler, Runnable e ProgressDialog - Ex02

Neste outro teste vamos simular uma operação demorada e mostrar a evolução do processamento através de um ProgressDialog com uma barra indicadora de progresso.

Alguns detalhes da implementação:
  No onClick() do botão eu chamo o método ativaThread() que faz duas coisas: primeiro prepara o ProgressDialog e segundo prepara a thread e a starta.
  Na thread fazemos uma contagem de 0 a 100 e a cada iteração enviamos uma atualização da barra de progresso, como estamos em uma thread que não a UI Thread usamos o handler-runnable para isso.
  Quando a contagem chega a 100, mudamos o status para concluído e setamos o status da thread para interrupted. (Só para não ficar parado no sleep).
   No final, antes de sair da thread o ProgressDialog é fechado e enviamos uma breve mensagem via toast.

Seguem os códigos.

package br.com.agorandroid.testethread02; import android.app.Activity; import android.os.Bundle; import android.app.ProgressDialog; import android.os.Handler; import android.view.View; import android.view.View.OnClickListener; import android.widget.Button; import android.widget.Toast; /** * @author A H Gusukuma * agorandroid.blogspot.com */ public class TesteThread02Activity extends Activity { Button button; ProgressThread progressThread; ProgressDialog progressDialog; Handler mHandler = new Handler(); /** Called when the activity is first created. */ @Override public void onCreate(Bundle savedInstanceState) { super.onCreate(savedInstanceState); setContentView(R.layout.main); button = (Button) findViewById(R.id.progressDialog); button.setOnClickListener(new OnClickListener() { public void onClick(View v) { ativaThread(); } }); } private void ativaThread() { progressDialog = new ProgressDialog(TesteThread02Activity.this); progressDialog.setProgressStyle(ProgressDialog.STYLE_HORIZONTAL); progressDialog.setMessage("Running..."); progressDialog.setCancelable(false); progressDialog.show(); progressThread = new ProgressThread(); progressThread.start(); } private class ProgressThread extends Thread { final static int STATE_DONE = 0; final static int STATE_RUNNING = 1; private volatile int mState; volatile int total; ProgressThread() { mState = STATE_RUNNING; total = 0; } public void run() { do { total++; mHandler.post(new Runnable() { @Override public void run() { progressDialog.setProgress(total);; } }); if (total>=100) { mState = STATE_DONE; Thread.currentThread().interrupt(); } try { Thread.sleep(100); } catch (InterruptedException e) { } } while(isRunning()); mHandler.post(new Runnable() { @Override public void run() { progressDialog.dismiss(); Toast.makeText(TesteThread02Activity.this, "Fim da Thread", Toast.LENGTH_SHORT).show(); } }); } public boolean isRunning() { return mState == STATE_RUNNING; } } }

<?xml version="1.0" encoding="utf-8"?> <linearlayout xmlns:android="http://schemas.android.com/apk/res/android" android:orientation="vertical" android:layout_width="fill_parent" android:layout_height="fill_parent" > <textview android:layout_width="fill_parent" android:layout_height="wrap_content" android:text="@string/hello" /> <button android:text="Progress Dialog" android:id="@+id/progressDialog" android:layout_width="fill_parent" android:layout_height="wrap_content"> </Button> </LinearLayout>

Vejam a app em execução:

Bons códigos!

PS: Alterei a variável total para volatile, pois ela é acessada por duas threads.

Thread, Handler, Runnable e ProgressDialog - Ex01

Neste teste vamos simular uma operação demorada com tempo indeterminado para terminar.
Como é uma operação demorada a regra número 1 nos diz para não bloquear a UI Thread, então vamos implementar uma thread para fazer o serviço.
Como não podemos alterar a tela diretamente (regra nº 2) vamos usar um handler e um runnable para atualizar a tela estando em outra thread que não a UI Thread.

Alguns detalhes da implementação:
  Eu extendo a classe Thread e no construtor eu informo um inteiro que é o número de loops que vou fazer para simular uma operação demorada (cada loop demora aproximadamente 1 segundo).
  No método fazerAlgoDemorado(), é o local onde faríamos uma consulta a um servidor, baixariamos um arquivo, ou uma sequência longa de cálculos.
  Antes de iniciar a thread é mostrado o ProgressDialog para informar ao usuário que o app vai iniciar uma operação longa. No final, antes de sair da thread o ProgressDialog é fechado e enviamos uma breve mensagem via toast. E como estamos em outra thread, fazemos isso via handler-runnable.

Seguem os códigos.

package br.com.agorandroid.testethread01; import android.app.Activity; import android.os.Bundle; import android.app.ProgressDialog; import android.os.Handler; import android.view.View; import android.view.View.OnClickListener; import android.widget.Button; import android.widget.Toast; /** * @author A H Gusukuma * agorandroid.blogspot.com */ public class TesteThread01Activity extends Activity { Button button; MyThread mThread; ProgressDialog mDialog; Handler mHandler; /** Called when the activity is first created. */ @Override public void onCreate(Bundle savedInstanceState) { super.onCreate(savedInstanceState); setContentView(R.layout.main); button = (Button) findViewById(R.id.iniciarthread); button.setOnClickListener(new OnClickListener() { public void onClick(View v) { ativaThread(); } }); } private void ativaThread() { mDialog = ProgressDialog.show(this, "Aguarde", "Processando...", false, false); mHandler = new Handler(); mThread = new MyThread(5); mThread.start(); } private class MyThread extends Thread { private int numLoops; public MyThread(int loops) { numLoops = loops; } public void run() { fazerAlgoDemorado(); mHandler.post(new Runnable() { @Override public void run() { mDialog.dismiss(); Toast.makeText(TesteThread01Activity.this, "Fim da Thread", Toast.LENGTH_LONG).show(); } }); } private void fazerAlgoDemorado() { int i = 0; do { try { Thread.sleep(1000); i++; } catch (InterruptedException e) { } } while (i<numLoops); } } }



<?xml version="1.0" encoding="utf-8"?> <linearlayout xmlns:android="http://schemas.android.com/apk/res/android" android:orientation="vertical" android:layout_width="fill_parent" android:layout_height="fill_parent" > <textview android:layout_width="fill_parent" android:layout_height="wrap_content" android:text="@string/hello" /> <button android:text="Iniciar Thread" android:id="@+id/iniciarthread" android:layout_width="fill_parent" android:layout_height="wrap_content"> </Button> </LinearLayout>

Olhem o programa em execução:

Bons códigos!