Cara menggunakan fungsi ScheduledThreadPoolExecutor dalam Java untuk penjadualan tugas berjadual

Memandangkan kerumitan sistem perisian terus meningkat, semakin banyak tugas tak segerak terlibat dalam sistem. Cara cekap menjadualkan tugas tak segerak ini adalah kemahiran yang diperlukan. Di Java, anda boleh menggunakan ScheduledThreadPoolExecutor untuk penjadualan tugas berjadual. Artikel ini akan memperkenalkan penggunaan asas ScheduledThreadPoolExecutor dan cara menggunakannya untuk melaksanakan penjadualan berjadual tugas tak segerak.

ScheduledThreadPoolExecutor ialah kelas terbina dalam Java yang melaksanakan penjadualan tugas berjadual. Ia mewarisi daripada kelas ThreadPoolExecutor, mempunyai semua ciri kumpulan benang, dan boleh melaksanakan tugas tertentu mengikut selang masa atau masa tunda yang ditentukan.

Untuk menggunakan ScheduledThreadPoolExecutor untuk menjadualkan tugas berjadual, anda perlu memenuhi syarat asas berikut:

1. Buat objek ScheduledThreadPoolExecutor

Apabila membuat ScheduledThreadPoolExecutor untuk menentukan objek kumpulan, anda perlu menentukan objek kumpulan benang. Saiz kumpulan benang menentukan bilangan tugasan yang boleh dilaksanakan secara serentak dan bilangan sumber yang diperlukan oleh tugasan tersebut. Apabila mencipta objek, anda boleh menentukan dua parameter, corePoolSize dan maximumPoolSize, yang masing-masing mewakili saiz kumpulan benang teras dan saiz kumpulan benang maksimum. Di sini kita boleh menetapkannya kepada nilai yang sama, iaitu menggunakan kumpulan benang saiz tetap.

2. Tentukan tugas Boleh Dijalankan atau Boleh Dipanggil

Tugas ScheduledThreadPoolExecutor dilaksanakan berdasarkan antara muka Runnable dan Callable dalam perpustakaan kelas Java. Apabila mentakrifkan tugas, anda boleh memilih Runnable atau Callable, dan anda boleh memilih kaedah pelaksanaan yang sepadan mengikut keperluan sebenar.

3. Nyatakan kaedah pelaksanaan tugas

Dalam ScheduledThreadPoolExecutor, anda boleh menentukan kaedah pelaksanaan tugas. Terdapat dua cara untuk dipilih: satu ialah menggunakan kaedah scheduleAtFixedRate(), satu lagi ialah menggunakan kaedah scheduleWithFixedDelay(). Perbezaan antara kedua-dua kaedah ini ialah kaedah scheduleAtFixedRate() melaksanakan tugas mengikut selang masa tetap, manakala kaedah scheduleWithFixedDelay() mengira masa pelaksanaan tugas seterusnya berdasarkan masa penyelesaian tugasan.

Di bawah, kami akan memperkenalkan langkah-langkah ini secara terperinci dengan kod.

1. Mencipta objek ScheduledThreadPoolExecutor

Berikut ialah kod sampel asas untuk mencipta objek ScheduledThreadPoolExecutor:

ScheduledExecutorService executor = Executors.newScheduledThreadPool(1);

Dalam kod ini, kami mencipta kumpulan benang bersaiz 1 menggunakan kelas utiliti Java's Executors. Memandangkan ScheduledThreadPoolExecutor mewarisi daripada kelas ThreadPoolExecutor, kami boleh menggunakan kaedah berkaitan kumpulan benang biasa untuk mengurus kumpulan benang.

2. Tentukan tugasan Boleh Dijalankan atau Boleh Dipanggil

Dalam ScheduledThreadPoolExecutor, anda boleh menggunakan antara muka Boleh Dijalankan dan Boleh Dipanggil untuk mentakrifkan tugasan, seperti:

Runnable task = new Runnable() {
    @Override
    public void run() {
        // 任务内容
    }
};

atau:

rreee dan cara yang boleh Dipanggil

As yang anda boleh lihat, Jalankan untuk mentakrifkan tugasan anda. antara muka adalah sangat serupa. Satu-satunya perbezaan ialah antara muka Boleh Panggil perlu mengembalikan nilai, manakala antara muka Runnable tidak.

3. Nyatakan kaedah pelaksanaan tugasan

Mengikut pengenalan sebelumnya, ScheduledThreadPoolExecutor menyediakan dua kaedah pelaksanaan tugas: scheduleAtFixedRate() dan scheduleWithFixedDelay(). Berikut menerangkan cara menggunakan kedua-dua kaedah ini masing-masing.

scheduleAtFixedRate()

Gunakan kaedah scheduleAtFixedRate() untuk melaksanakan tugasan tetap Ia menerima 4 parameter, iaitu:

1. Tugas yang akan dilaksanakan
2. masa kelewatan tugasan pertama. selang pelaksanaan Masa
3. Unit selang masa
Berikut ialah contoh kaedah scheduleAtFixedRate():

Callable<String> task = new Callable<String>() {
    @Override
    public String call() throws Exception {
        // 任务内容
        return null;
    }
};

Kod ini bermakna selepas kelewatan 0 saat, tugasan akan dilaksanakan setiap 1 saat. Kandungan tugasan perlu dilaksanakan dalam Runnable atau Callable yang ditakrifkan sebelum ini.

scheduleWithFixedDelay()

Serupa dengan kaedah scheduleAtFixedRate(), kaedah scheduleWithFixedDelay() juga menerima 4 parameter, iaitu:

Tugas yang akan dilaksanakan

1. masa perlaksanaan pertama tugasan
2. Unit masa kelewatan
3. Masa kelewatan untuk penyiapan pelaksanaan tugas
4. Unit masa kelewatan untuk penyiapan pelaksanaan tugas
5. Berikut ialah contoh kaedah scheduleWithFixedDelay():

rreee

Kod ini adalah yang pertama dilaksanakan selepas kelewatan 0 saat, dan kemudian Selepas pelaksanaan tugas selesai, laksanakan semula tugasan dengan kelewatan selama 1 saat. Kandungan tugasan perlu dilaksanakan dalam Runnable atau Callable yang ditakrifkan sebelum ini.

Kami telah memperkenalkan cara menggunakan ScheduledThreadPoolExecutor untuk menjadualkan tugasan yang dijadualkan. Mari kita ringkaskan kelebihan dan kekurangan ScheduledThreadPoolExecutor.

Kelebihan:

Boleh melaksanakan berbilang tugas pada masa yang sama

1. Keupayaan untuk mengurus bilangan benang dalam kumpulan benang
2. Boleh melaraskan masa pelaksanaan tugas secara fleksibel
3. Menyediakan fungsi yang berkuasa dijadualkan pada selang masa tertentu Perlaksanaan
4. Kelemahan:

1. Tidak boleh mendapatkan status tugas dan keputusan secara tak segerak
2. Tidak boleh menambah atau mengurangkan bilangan tugas secara dinamik

Ringkasnya, ScheduledThreadPoolExecutor ialah penjadual tugas berjadual yang sangat praktikal di Java, yang boleh membantu kami mengurus dan Menjadualkan tugasan dengan cekap. Dalam pembangunan sebenar, kami boleh menggunakannya mengikut keperluan perniagaan tertentu dan menggabungkannya dengan perpustakaan kelas Java yang lain untuk mencapai keperluan penjadualan tugas yang lebih kompleks.

Atas ialah kandungan terperinci Cara menggunakan fungsi ScheduledThreadPoolExecutor dalam Java untuk penjadualan tugas berjadual. Untuk maklumat lanjut, sila ikut artikel berkaitan lain di laman web China PHP!