Java 类org.greenrobot.eventbus.util.AsyncExecutor 实例源码

public void buscarPorLogin(final String login, final String senha) {
    //TODO: Substituir a implementação abaixo pela implementação utilizando Firebase
    final Usuario usuario = new Usuario();
    usuario.setId("123");
    usuario.setNome("Cleber Alcântara");
    usuario.setLogin("cleber");
    usuario.setSenha("cleber");

    AsyncExecutor.create().execute(
        new AsyncExecutor.RunnableEx() {
            @Override
            public void run() throws Exception {
                if (usuario.getLogin().equals(login) && usuario.getSenha().equals(senha)) {
                    EventBus.getDefault().post(new DatabaseEvent<>(usuario));
                } else {
                    throw new Exception("Usuário e/ou senha inválidos");
                }
            }
        }
    );
}

public App() {
    threadPool = AsyncExecutor.create();
}

public void runThreadInPool(final AsyncExecutor.RunnableEx runnable) {
    threadPool.execute(runnable);
}

public void buscarAtendimentos(final List<Agenda> agendas, final Calendar diaOcorrencia) {
    //TODO: Substituir a implementação stub abaixo pela implementação correta
    AsyncExecutor.create().execute(
        new AsyncExecutor.RunnableEx() {
            @Override
            public void run() throws Exception {
                List<Atendimento> atendimentos = new ArrayList<>();
                Atendimento atendimento = new Atendimento();
                atendimento.setAgenda(agendas.get(0));
                atendimento.setPaciente(new Paciente());
                atendimento.getPaciente().setNome("Patrícia Silva");
                atendimento.setHoraInicio(Calendar.getInstance());
                atendimento.getHoraInicioCalendar().set(Calendar.HOUR_OF_DAY, 9);
                atendimento.getHoraInicioCalendar().set(Calendar.MINUTE, 0);

                atendimento.setHoraFim(Calendar.getInstance());
                atendimento.getHoraFimCalendar().set(Calendar.HOUR_OF_DAY, 9);
                atendimento.getHoraFimCalendar().set(Calendar.MINUTE, 20);

                if (atendimento.mesmaDataInicio(diaOcorrencia)) {
                    atendimentos.add(atendimento);
                }

                atendimento = new Atendimento();
                atendimento.setAgenda(agendas.get(1));
                atendimento.setPaciente(new Paciente());
                atendimento.getPaciente().setNome("João Roberto");
                atendimento.setHoraInicio(Calendar.getInstance());
                atendimento.getHoraInicioCalendar().set(Calendar.HOUR_OF_DAY, 15);
                atendimento.getHoraInicioCalendar().set(Calendar.MINUTE, 00);

                atendimento.setHoraFim(Calendar.getInstance());
                atendimento.getHoraFimCalendar().set(Calendar.HOUR_OF_DAY, 16);
                atendimento.getHoraFimCalendar().set(Calendar.MINUTE, 00);

                if (atendimento.mesmaDataInicio(diaOcorrencia)) {
                    atendimentos.add(atendimento);
                }

                Thread.sleep(500);

                EventBus.getDefault().post(new PaginadorDiasEvent<>(atendimentos, diaOcorrencia));
            }
        }
    );
}

/**
 * Busca todas as atuações de um usuário.
 *
 * @param usuario usuário pelo qual as ocupações serão procuradas.
 */
public void buscarPorUsuario(Usuario usuario) {
    //TODO: Substituir a implementação stub abaixo pela implementação correta quando a DAO for desenvolvida.
    AsyncExecutor.create().execute(
        new AsyncExecutor.RunnableEx() {
            @Override
            public void run() throws Exception {
                List<Atuacao> atuacoes = new LinkedList<Atuacao>();
                SimpleDateFormat format = new SimpleDateFormat("dd/MM/yyyy");
                Atuacao atuacao;
                LocalAtendimento localAtendimento;
                ProfissionalSaude profissionalSaude;

                atuacao = new Atuacao();
                atuacao.setDataInicio(format.parse("01/01/2010"));
                atuacao.setDataFim(null);
                localAtendimento = new LocalAtendimento();
                localAtendimento.setNome("Hospital das Clínicas - UFG");
                atuacao.setLocalAtendimento(localAtendimento);
                profissionalSaude = new ProfissionalSaude();
                profissionalSaude.setUsuario(new Usuario());
                profissionalSaude.getUsuario().setNome("Fulano da Silva");
                atuacao.setProfissional(profissionalSaude);
                atuacoes.add(atuacao);

                atuacao = new Atuacao();
                atuacao.setDataInicio(format.parse("01/09/1987"));
                atuacao.setDataFim(null);
                localAtendimento = new LocalAtendimento();
                localAtendimento.setNome("Hospital de Urgências de Goiânia");
                atuacao.setLocalAtendimento(localAtendimento);
                profissionalSaude = new ProfissionalSaude();
                profissionalSaude.setUsuario(new Usuario());
                profissionalSaude.getUsuario().setNome("Fulano da Silva");
                atuacao.setProfissional(profissionalSaude);
                atuacoes.add(atuacao);

                atuacao = new Atuacao();
                atuacao.setDataInicio(format.parse("01/01/2015"));
                atuacao.setDataFim(format.parse("01/01/2016"));
                localAtendimento = new LocalAtendimento();
                localAtendimento.setNome("Santa Casa de Misericórdia de Goiânia");
                atuacao.setLocalAtendimento(localAtendimento);
                profissionalSaude = new ProfissionalSaude();
                profissionalSaude.setUsuario(new Usuario());
                profissionalSaude.getUsuario().setNome("Fulano da Silva");
                atuacao.setProfissional(profissionalSaude);
                atuacoes.add(atuacao);

                atuacao = new Atuacao();
                atuacao.setDataInicio(format.parse("01/01/2015"));
                atuacao.setDataFim(format.parse("01/01/2016"));
                localAtendimento = new LocalAtendimento();
                localAtendimento.setNome("Hospital Araujo Jorge");
                atuacao.setLocalAtendimento(localAtendimento);
                profissionalSaude = new ProfissionalSaude();
                profissionalSaude.setUsuario(new Usuario());
                profissionalSaude.getUsuario().setNome("Fulano da Silva");
                atuacao.setProfissional(profissionalSaude);
                atuacoes.add(atuacao);

                Thread.sleep(2000);

                EventBus.getDefault().post(new DatabaseEvent<>(atuacoes));
            }
        }
    );
}

/**
 * Busca todos todas as atuações de profissionais de saúde que trabalham em determinados locais de atendimento.
 *
 * @param locaisAtendimento Lista de locais de atendimento que será utilizada para se buscar as atuações de profissionais de saúde.
 */
public void buscarPorLocais(final List<LocalAtendimento> locaisAtendimento) {
    //TODO: Substituir a implementação stub abaixo pela implementação correta quando a DAO for desenvolvida.
    AsyncExecutor.create().execute(
        new AsyncExecutor.RunnableEx() {
            @Override
            public void run() throws Exception {
                List<Atuacao> atuacoes = new LinkedList<Atuacao>();
                ProfissionalSaude profissionalSaude;
                Atuacao atuacao;
                atuacao = new Atuacao();
                atuacao.setLocalAtendimento(locaisAtendimento.get(0));
                profissionalSaude = new ProfissionalSaude();
                profissionalSaude.setUsuario(new Usuario());
                profissionalSaude.getUsuario().setNome("Joao Pereira");
                atuacao.setProfissional(profissionalSaude);
                atuacoes.add(atuacao);

                atuacao = new Atuacao();
                atuacao.setLocalAtendimento(locaisAtendimento.get(0));
                profissionalSaude = new ProfissionalSaude();
                profissionalSaude.setUsuario(new Usuario());
                profissionalSaude.getUsuario().setNome("Paulo Roberto");
                atuacao.setProfissional(profissionalSaude);
                atuacoes.add(atuacao);

                atuacao = new Atuacao();
                atuacao.setLocalAtendimento(locaisAtendimento.get(1));
                profissionalSaude = new ProfissionalSaude();
                profissionalSaude.setUsuario(new Usuario());
                profissionalSaude.getUsuario().setNome("Mário Roberto");
                atuacao.setProfissional(profissionalSaude);
                atuacoes.add(atuacao);

                atuacao = new Atuacao();
                atuacao.setLocalAtendimento(locaisAtendimento.get(1));
                profissionalSaude = new ProfissionalSaude();
                profissionalSaude.setUsuario(new Usuario());
                profissionalSaude.getUsuario().setNome("Roberto Alves");


                atuacao.setProfissional(profissionalSaude);
                atuacoes.add(atuacao);

                atuacao = new Atuacao();
                atuacao.setLocalAtendimento(locaisAtendimento.get(2));
                profissionalSaude = new ProfissionalSaude();
                profissionalSaude.setUsuario(new Usuario());
                profissionalSaude.getUsuario().setNome("Joao Pereira");
                atuacao.setProfissional(profissionalSaude);
                atuacoes.add(atuacao);

                Thread.sleep(2000);

                EventBus.getDefault().post(new DatabaseEvent<>(atuacoes));
            }
        }
    );
}