Bagaimana untuk menyelesaikan pengecualian tamat masa gangguan thread Java (ThreadInterruptedTimeoutExceotion)

Cara menyelesaikan pengecualian tamat masa gangguan Java (ThreadInterruptedTimeoutException)

Dalam pengaturcaraan berbilang benang Java, kita sering menghadapi situasi di mana masa pelaksanaan benang terlalu lama. Untuk mengelakkan utas daripada menduduki terlalu banyak sumber sistem, kami biasanya menetapkan tamat masa Apabila masa pelaksanaan utas melebihi tamat masa, kami berharap dapat mengganggu pelaksanaan utas.

Java menyediakan mekanisme gangguan thread Dengan memanggil kaedah interrupt() thread, anda boleh menghantar isyarat interrupt ke thread. Apabila kami memanggil kaedah interrupt() thread, kami tidak segera mengganggu pelaksanaan thread, tetapi mengeluarkan permintaan interrupt kepada thread dan menetapkan bit flag interrupt thread kepada true. Semasa pelaksanaan, benang boleh menentukan sama ada ia telah diganggu dengan menyemak bit bendera gangguannya sendiri, dan menamatkan pelaksanaannya seperti yang diperlukan.

Dalam pengaturcaraan berbilang benang, kadangkala kita mahu menunggu hasil operasi dalam tempoh tamat masa dan mengganggu pelaksanaan utas apabila tempoh tamat masa tiba. Contoh biasa ialah pengendalian tamat masa permintaan rangkaian. Kita boleh menyelesaikan masalah ini dengan cara berikut.

Pertama, kita perlu mencipta kelas benang untuk melaksanakan operasi yang perlu kita tunggu. Dalam kelas thread ini, kita perlu menggunakan kaedah sleep() thread untuk mensimulasikan operasi yang perlu kita tunggu.

public class MyThread implements Runnable {
    @Override
    public void run() {
        try {
            // 模拟需要等待的操作
            Thread.sleep(5000);
        } catch (InterruptedException e) {
            // 线程被中断，做一些清理工作
            System.out.println("线程被中断");
        }
    }
}

Seterusnya, kami mencipta utas utama untuk memulakan utas kami dan menetapkan tamat masa.

public class Main {
    public static void main(String[] args) {
        MyThread myThread = new MyThread();
        Thread thread = new Thread(myThread);

        // 设置超时时间
        int timeout = 3000;

        // 启动线程
        thread.start();

        try {
            // 等待线程执行完毕或超时
            thread.join(timeout);

            // 如果线程未执行完毕，则中断线程
            if (thread.isAlive()) {
                thread.interrupt();
            }
       } catch (InterruptedException e) {
           e.printStackTrace();
       }
    }
}

Dalam kod di atas, kami menggunakan kaedah join() kelas Thread untuk menunggu thread menyelesaikan pelaksanaan atau tamat masa. Jika utas selesai melaksanakan, kaedah join() akan kembali serta-merta jika tempoh tamat masa melebihi dan kaedah join() tidak kembali, kita boleh menganggap bahawa pelaksanaan utas telah tamat masa dan mengganggu pelaksanaan utas dengan memanggil utas itu. kaedah interrupt().

Dalam kod di atas, kami menggunakan kaedah sleep() dalam kaedah run() thread untuk mensimulasikan operasi menunggu dan menetapkan masa menunggu yang lebih besar (5000 milisaat). Dalam urutan utama, kami menetapkan tamat masa yang singkat (3000 milisaat). Dengan cara ini, apabila pelaksanaan thread melebihi 3 saat, kami akan mengganggu pelaksanaan thread.

Melalui kod di atas, kami boleh menyelesaikan masalah tamat masa gangguan benang dalam pengaturcaraan berbilang benang Java. Kami boleh menetapkan tamat masa yang berbeza berdasarkan keperluan khusus dan menggunakan kaedah ini untuk mengendalikan tamat masa pelaksanaan benang. Pada masa yang sama, kami juga perlu mengendalikan gangguan thread dengan betul dalam kaedah run() thread dan melakukan beberapa kerja pembersihan untuk memastikan operasi program yang betul.

Atas ialah kandungan terperinci Bagaimana untuk menyelesaikan pengecualian tamat masa gangguan thread Java (ThreadInterruptedTimeoutExceotion). Untuk maklumat lanjut, sila ikut artikel berkaitan lain di laman web China PHP!