安排Asynctask - 虽然？服务？计时器？

好吧，我得到Togglebutton，开始service。该服务在onStartCommand中启动新的Thread。在此线程中执行Asynctask。安排Asynctask - 虽然？服务？计时器？

现在我想要这个Asynctask例如每5秒执行一次。 Asynctask检查网站是否可用。 - >如果没有，后5秒再次检查 - >如果是，节目信息并停止

请告诉我与我的已经存在的代码的最佳方法：

public class NotifiyService extends Service { 

    String savedsa; 
    Thread Th1; 
    boolean value; 


    final class TheThread implements Runnable{ 
     int serviceID; 
     String savedsa1; 
     TheThread(int serviceID,String savedsa){ 
      this.serviceID = serviceID; 
      this.savedsa1 = savedsa; 
     } 

     @Override 
     public void run() { 
      HttpTaskParams httpparams = new HttpTaskParams(value,savedsa1); 
      new HttpTask().execute(httpparams); 
      } 
    } 
    public NotifiyService() { 
    } 

    @Override 
    public void onCreate() { 
     super.onCreate(); 
    } 


    @Override 
    public int onStartCommand(Intent intent, int flags, int startId) { 
     SharedPreferences sharedPreferences7 = getSharedPreferences("Prefsa",MODE_WORLD_READABLE); 
     savedsa = sharedPreferences7.getString("keysa",""); 
     Toast.makeText(NotifiyService.this,getResources().getString(R.string.MonStarted)+ "\n" + savedsa,Toast.LENGTH_LONG).show(); 
     Th1 = new Thread(new TheThread(startId,savedsa)); 
     Th1.start(); 
     return START_STICKY; 
    } 

    @Override 
    public void onDestroy() { 
     //super.onDestroy(); 
     Toast.makeText(NotifiyService.this,getResources().getString(R.string.MonStopped), Toast.LENGTH_LONG).show(); 

    } 

    @Override 
    public IBinder onBind(Intent intent) { 
     // TODO: Return the communication channel to the service. 
     return null; 
    } 

    private static class HttpTaskParams{ 
     boolean value; 
     String address; 

     HttpTaskParams(boolean value, String address){ 
      this.value = value; 
      this.address = address; 
     } 

    } 

    private class HttpTask extends AsyncTask<HttpTaskParams,Void,Boolean>{ 

     @Override 
     protected Boolean doInBackground(HttpTaskParams... params) { 
      boolean value = params[0].value; 
      String address = params[0].address; 

       try { 
        URL url = new URL(address); 
        HttpURLConnection httpURLConnection = (HttpURLConnection) url.openConnection(); 
        httpURLConnection.setRequestMethod("HEAD"); 
        httpURLConnection.setConnectTimeout(3000); 
        httpURLConnection.setReadTimeout(3000); 
        httpURLConnection.connect(); 
        value = true; 
        return value; 
       } catch (MalformedURLException e) { 
        e.printStackTrace(); 
        value = false; 
        return value; 
       } catch (IOException e) { 
        e.printStackTrace(); 
        value = false; 
        return value; 
       } 
     } 
     @Override 
     protected void onPostExecute(Boolean result) { 
      if(result){ 
       Toast.makeText(NotifiyService.this,"true",Toast.LENGTH_SHORT).show(); 

       //Notification in Status Bar 
       NotificationCompat.Builder builder = new NotificationCompat.Builder(NotifiyService.this); 
       builder.setSmallIcon(R.drawable.dummy); 
       Intent intent = new Intent(NotifiyService.this, Main2Activity.class); 
       intent.setAction(Intent.ACTION_MAIN); 
       intent.addCategory(Intent.CATEGORY_LAUNCHER); 
       intent.addFlags(Intent.FLAG_ACTIVITY_NEW_TASK); 
       PendingIntent pendingIntent = PendingIntent.getActivity(NotifiyService.this,0,intent,0); 
       builder.setContentIntent(pendingIntent); 
       builder.setLights(Color.YELLOW,600,600); 
       builder.setSound(RingtoneManager.getDefaultUri(RingtoneManager.TYPE_NOTIFICATION)); 
       builder.setLargeIcon(BitmapFactory.decodeResource(getResources(), R.drawable.dummy)); 
       builder.setContentTitle(getResources().getString(R.string.newNotify)); 
       builder.setContentText(getResources().getString(R.string.newNotify2)); 
       builder.setAutoCancel(true); 
       NotificationManager notificationManager = (NotificationManager) getSystemService(NOTIFICATION_SERVICE); 
       notificationManager.notify(1,builder.build()); 

      } 
      else{ 
       Toast.makeText(NotifiyService.this,"false",Toast.LENGTH_SHORT).show(); 
      } 
     } 
    } 
}

编辑：

@Override 
    public void run() { 
      ScheduledExecutorService checkreg = Executors.newScheduledThreadPool(1); 
      scheduledFuture = checkreg.scheduleAtFixedRate(new Runnable() { 
       @Override 
       public void run() { 
        HttpTaskParams httpparams = new HttpTaskParams(value, savedsa1); 
        new HttpTask().execute(httpparams); 
       } 
      }, 0, 20, TimeUnit.SECONDS);} 

@Override 
    public void onDestroy() { 
     //super.onDestroy(); 
     Th1.interrupt(); 
     scheduledFuture.cancel(false); 
     Toast.makeText(NotifiyService.this,getResources().getString(R.string.MonStopped), Toast.LENGTH_LONG).show(); 
     stopSelf(); 
    }

来源

2016-02-29 Patrick260284

我认为ScheduledExecutorService可以帮到你。请检查this的答案。请让我知道，如果这可以帮助你。

来源

2016-02-29 16:14:02 Kerkhofsd

哎，是的，它与感谢:-)工作，但现在我还有一个 “问题”。它不会停止。我的togglebutton启动和停止服务，但似乎线程仍在运行。我读过'Thread.stop'不太好。你有建议吗？ – Patrick260284

若要正确停止'scheduleTaksExecutor'，请将'scheduleTaskExecutor.scheduleAtFixedRate（...）'的结果保存在一个变量中，并调用此结果的cancel方法（例如在您的服务的onDestroy中）。这有帮助吗？ – Kerkhofsd

我明白你的意思，但不知道如何从scheduleatFixedRate（）获得结果。 – Patrick260284

试试这个/ ** *定期从网络加载汇率 *返回广播消息的结果。 *由koss于19.02.16创建。 * */ 公共类EcbEuropeService延伸服务{

public static final String ECB_URL = "http://www.ecb.europa.eu/stats/eurofxref/eurofxref-daily.xml"; 
public static final int UPDATE_PERIOD = 30000; 
public static final int UPDATE_TICK = 1000; 

public static final String NOTIFICATION = "koss.ru.oneclickrate.receiver"; 
public static final String EXTRA_CURRENCIES_MAP = "extra_currencies_map"; 

@Override 
public int onStartCommand(Intent intent, int flags, int startId) { 
    getUrlData(); 
    return Service.START_NOT_STICKY; 
} 

@Override 
public IBinder onBind(Intent intent) { 
    return null; 
} 

public Cubes getUrlData() { 
    (new AsyncTask<Object, Object, Cubes>() { 
     Map<CurrencyType, BigDecimal> result = new EnumMap<CurrencyType, BigDecimal>(CurrencyType.class); 

     @Override 
     protected Cubes doInBackground(Object... params) { 
      Cubes cubes = new Cubes(); 
      InputStream is = null; 
      HttpURLConnection urlConnection = null; 
      try { 
       URL url = new URL(ECB_URL); 
       urlConnection = (HttpURLConnection) url.openConnection(); 
       is = urlConnection.getInputStream(); 
       cubes = EcbEuropeResponseParser.parse(is); 
      } catch (Exception e) { 
       e.printStackTrace(); 
      } finally { 
       if(urlConnection!=null) IOUtils.close(urlConnection); 
       if(is!=null) IOUtils.closeQuietly(is); 
       return cubes; 
      } 
     } 

     @Override 
     protected void onPostExecute(Cubes map) { 
      super.onPostExecute(map); 
      sendBroadcastMessage(map); 
      startTimer(); 
     } 
    }).execute(); 
    return null; 
} 

/** 
* Restarts timer 
* */ 
public void startTimer() { 
    cdt.cancel(); 
    cdt.start(); 
} 

CountDownTimer cdt = new CountDownTimer(UPDATE_PERIOD, UPDATE_TICK) { 
    @Override 
    public void onTick(long millisUntilFinished) { 

    } 

    public void onFinish() { 
     getUrlData(); 
    } 
}; 

private void sendBroadcastMessage(Cubes currenciesMap) { 
    Intent intent = new Intent(NOTIFICATION); 
    intent.putExtra(EXTRA_CURRENCIES_MAP, currenciesMap); 
    sendBroadcast(intent); 
}

}

来源

2016-02-29 16:35:43

安排Asynctask - 虽然？服务？计时器？

回答

相关问题