android - 如何每 X 秒运行一次方法

Question

我正在开发一个 Android 2.3.3 应用程序，我需要每X seconds运行一个方法。

在 iOS 中，我有NSTimer，但在 Android 中我不知道该使用什么。

有人推荐我Handler；另一个推荐我AlarmManager但我不知道哪种方法更适合NSTimer。

这是我想在 Android 中实现的代码：

timer2 = [
    NSTimer scheduledTimerWithTimeInterval:(1.0f/20.0f)
    target:self
    selector:@selector(loopTask)
    userInfo:nil
    repeats:YES
];

timer1 = [
    NSTimer scheduledTimerWithTimeInterval:(1.0f/4.0f)
    target:self
    selector:@selector(isFree)
    userInfo:nil
    repeats:YES
];

我需要类似NSTimer的东西。

你给我推荐什么？

score 190 · Accepted Answer

您将使用的解决方案实际上取决于您在每次执行函数之间需要等待多长时间。

如果您等待超过 10 分钟，我建议您使用AlarmManager.

// Some time when you want to run
Date when = new Date(System.currentTimeMillis());

try {
    Intent someIntent = new Intent(someContext, MyReceiver.class); // intent to be launched

    // Note: this could be getActivity if you want to launch an activity
    PendingIntent pendingIntent = PendingIntent.getBroadcast(
        context,
        0, // id (optional)
        someIntent, // intent to launch
        PendingIntent.FLAG_CANCEL_CURRENT // PendingIntent flag
    );

    AlarmManager alarms = (AlarmManager) context.getSystemService(
        Context.ALARM_SERVICE
    );

    alarms.setRepeating(
        AlarmManager.RTC_WAKEUP,
        when.getTime(),
        AlarmManager.INTERVAL_FIFTEEN_MINUTES,
        pendingIntent
    );
} catch(Exception e) {
    e.printStackTrace();
}

广播上述Intent内容后，您可以Intent通过实施BroadcastReceiver. 请注意，这需要在您的应用程序清单中或通过该context.registerReceiver(receiver, intentFilter);方法进行注册。有关BroadcastReceiver's 的更多信息，请参阅官方文档。.

public class MyReceiver extends BroadcastReceiver {
    @Override
    public void onReceive(Context context, Intent intent)
    {
        System.out.println("MyReceiver: here!") // Do your work here
    }
}

如果您等待的时间少于 10 分钟，那么我建议您使用Handler.

final Handler handler = new Handler();
final int delay = 1000; // 1000 milliseconds == 1 second

handler.postDelayed(new Runnable() {
    public void run() {
        System.out.println("myHandler: here!"); // Do your work here
        handler.postDelayed(this, delay);
    }
}, delay);

score 119 · Accepted Answer

每秒使用计时器...

new Timer().scheduleAtFixedRate(new TimerTask() {
    @Override
    public void run() {
        //your method
    }
}, 0, 1000);//put here time 1000 milliseconds=1 second

score 93 · Accepted Answer

您可以尝试此代码通过 onResume() 每 15 秒调用一次处理程序，并在活动不可见时通过 onPause() 停止它。

Handler handler = new Handler();
Runnable runnable;
int delay = 15*1000; //Delay for 15 seconds.  One second = 1000 milliseconds.


@Override
protected void onResume() {
   //start handler as activity become visible

    handler.postDelayed( runnable = new Runnable() {
        public void run() {
            //do something

            handler.postDelayed(runnable, delay);
        }
    }, delay);

    super.onResume();
}

// If onPause() is not included the threads will double up when you 
// reload the activity 

@Override
protected void onPause() {
    handler.removeCallbacks(runnable); //stop handler when activity not visible
    super.onPause();
}

score 20 · Accepted Answer

如果你熟悉 RxJava，你可以使用 Observable.interval()，它非常简洁。

Observable.interval(60, TimeUnits.SECONDS)
          .flatMap(new Function<Long, ObservableSource<String>>() {
                @Override
                public ObservableSource<String> apply(@NonNull Long aLong) throws Exception {
                    return getDataObservable(); //Where you pull your data
                }
            });

这样做的缺点是您必须以不同的方式构建轮询数据的架构。但是，响应式编程方式有很多好处：

您可以创建订阅的数据流，而不是通过回调控制数据。这将“轮询数据”逻辑和“用您的数据填充 UI”逻辑的关注点分开，这样您就不会混淆您的“数据源”代码和您的 UI 代码。

使用 RxAndroid，您只需 2 行代码即可处理线程。

Observable.interval(60, TimeUnits.SECONDS)
      .flatMap(...) // polling data code
      .subscribeOn(Schedulers.newThread()) // poll data on a background thread
      .observeOn(AndroidSchedulers.mainThread()) // populate UI on main thread
      .subscribe(...); // your UI code

请查看 RxJava。它有很高的学习曲线，但它会让在 Android 中处理异步调用变得更加容易和清洁。

score 9 · Accepted Answer

使用 Kotlin，我们现在可以为此创建一个通用函数！

object RepeatHelper {
    fun repeatDelayed(delay: Long, todo: () -> Unit) {
        val handler = Handler()
        handler.postDelayed(object : Runnable {
            override fun run() {
                todo()
                handler.postDelayed(this, delay)
            }
        }, delay)
    }
}

要使用，只需执行以下操作：

val delay = 1000L
RepeatHelper.repeatDelayed(delay) {
    myRepeatedFunction()
}

score 5 · Accepted Answer

    new CountDownTimer(120000, 1000) {

        public void onTick(long millisUntilFinished) {
            txtcounter.setText(" " + millisUntilFinished / 1000);

        }

        public void onFinish() {

            txtcounter.setText(" TimeOut  ");
            Main2Activity.ShowPayment = false;
            EventBus.getDefault().post("go-main");

        }

    }.start();

score 2 · Accepted Answer

这里我在 onCreate() 一个Activity中重复使用了一个线程，定时器在某些情况下不允许一切线程是解决方案

     Thread t = new Thread() {
        @Override
        public void run() {
            while (!isInterrupted()) {
                try {
                    Thread.sleep(10000);  //1000ms = 1 sec
                    runOnUiThread(new Runnable() {
                        @Override
                        public void run() {

                            SharedPreferences mPrefs = getSharedPreferences("sam", MODE_PRIVATE);
                            Gson gson = new Gson();
                            String json = mPrefs.getString("chat_list", "");
                            GelenMesajlar model = gson.fromJson(json, GelenMesajlar.class);
                            String sam = "";

                            ChatAdapter adapter = new ChatAdapter(Chat.this, model.getData());
                            listview.setAdapter(adapter);
                           // listview.setStackFromBottom(true);
                          //  Util.showMessage(Chat.this,"Merhabalar");
                        }
                    });

                } catch (InterruptedException e) {
                    e.printStackTrace();
                }
            }
        }
    };

    t.start();

如果需要，可以通过以下方式停止

@Override
protected void onDestroy() {
    super.onDestroy();
    Thread.interrupted();
    //t.interrupted();
}

score 0 · Accepted Answer

我这样做并且效果很好（代码是用Kotlin编写的）：

private lateinit var runnable: Runnable

private var handler = Handler(Looper.getMainLooper())

private val repeatPeriod: Long = 10000

然后从你的函数内部重新初始化可运行文件

runnable = Runnable {

        // Your code goes here

        handler.postDelayed(runnable, repeatPeriod)

    }

    handler.postDelayed(runnable, repeatPeriod)

}

请注意，如果您不两次postDelay处理程序，则循环不会是无限的！

android - 如何每 X 秒运行一次方法

8 回答 8

Related

Reference