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);
            
            }
        }
       
    }
 

                ExecutorService executor =  Executors.newSingleThreadExecutor();
                for (int i = 1; i <= numTasks; i++) {
                    Runnable worker = new MyTask("task" +i, 5);
                    executor.submit(worker);
                }
 

                    Runnable worker1 = new MyTask1("task1");
                    executor.submit(worker1);
                    Runnable worker2 = new MyTask2("task2");
                    executor.submit(worker2);
                    . . .        
                    Runnable workerN = new MyTaskN("taskN");
                    executor.submit(workerN);