Salah satu perubahan pada Java 2 untuk mengurangi kemungkinan
terjadinya deadlock adalah dengan dideprekasi (artinya pengembangannya
dihentikan, dan user disarankan untuk menghindari penggunaannya) metode
Continue Reading...
stop()
, suspend()
, dan resume()
pada kelas Thread
.
Alasan mengapa metode stop()
dideprekasi adalah karena metode ini tidak melepas kunci yang sudah
dimilikinya, dan jika objek tersebut berada dalam kondisi "cacat"
seperti ini, thread lain bisa melihat dan mengubah objek cacat ini.
Hasilnya akan muncul masalah yang tersembunyi yang akan sangat sulit
dideteksi.
Java menyediakan cara lain untuk menghentikan thread,
yaitu dengan mengeset suatu variabel untuk memberi tahu thread tersebut
agar menghentikan dirinya sendiri yaitu dengan keluar dari metode run()
-nya. Variabel ini akan dicek pada metode run()
yang jika bernilai true, maka metode run()
akan berhenti. Berikut ini adalah contohnya :
package com.lyracc.hentikanthread;
import java.util.*;
class Berhenti extends Thread {
// Harus bertipe volatile:
private volatile boolean stop = false;
private int hitung = 0;
public void run() {
// Jika stop masih bernilai false teruskan cetak angka
// Jika stop bernilai true, blok ini tidak lagi dijalankan
while (!stop && hitung < 10000) {
System.out.println(hitung++);
}
// Jika stop berubah menjadi true
if (stop)
System.out.println("Permintaan stop dideteksi");
}
public void requestStop() {
stop = true;
}
}
public class HentikanThread {
/**
* @param args
*/
public static void main(String[] args) {
final Berhenti threadBaru = new Berhenti();
threadBaru.start();
new Timer(true).schedule(new TimerTask() {
public void run() {
System.out.println("Permintaan berhenti");
threadBaru.requestStop();
}
}, 500); // run() setelah 500 mili detik
}
}
Variabel
Menginterupsi Thread yang Diblok
Kadang-kadang, ketika thread dalam keadaan diblok (misalnya ketika sedang menunggu input), thread tersebut tidak bisa membaca variabel seperti kita lakukan di atas. Di sini, kita bisa menggunakan metode
stop
harus bertipe volatile
sehingga metode run()
pasti bisa melihat variabel ini (jika tidak, maka nilainya bisa saja
di-cache). Tugas thread ini adalah mencetak 10000 angka, yang akan
berhenti ketika hitung >= 10000
atau objek lain meminta berhenti dengan memanggil requestStop()
. Perhatikan bahwa requestStop()
tidak synchronized
karena stop
bertipe boolean
dan volatile
(mengubah boolean menjadi [code]true
adalah operasi atomis yang tidak bisa dihentikan di tengah jalan, karena dilakukan dalam 1 clock).
Pada main()
, objek Berhenti
dimulai. Pada saat yang sama, Timer
dimulai untuk memanggil requestStop()
setelah setengah detik (500 mili detik). Konstruktor Timer
diisi true
untuk memastikan bahwa program berhenti saat itu juga.
Menginterupsi Thread yang Diblok
Kadang-kadang, ketika thread dalam keadaan diblok (misalnya ketika sedang menunggu input), thread tersebut tidak bisa membaca variabel seperti kita lakukan di atas. Di sini, kita bisa menggunakan metode
interrupt()
pada kelas Thread
untuk mengeluarkannya dari kondisi diblok. Misalnya,
package com.lyracc.interupsi;
import java.util.*;
class ThreadDiblok extends Thread {
public ThreadDiblok() {
System.out.println("Memulai blokade");
start();
}
public void run() {
try {
synchronized (this) {
wait(); // Memblok selamanya
}
} catch (InterruptedException e) {
System.out.println("Diinterupsi");
}
System.out.println("Keluar dari run()");
}
}
public class Interupsi {
static ThreadDiblok threadDiBlok = new ThreadDiblok();
/**
* @param args
*/
public static void main(String[] args) {
new Timer(true).schedule(new TimerTask() {
public void run() {
System.out.println("Bersiap-siap untuk interupsi");
threadDiBlok.interrupt();
threadDiBlok = null; // buat null untuk diambil oleh pemulung memori
}
}, 2000); // run() setelah 2 detik
}
}
Panggilan wait()
di dalam ThreadDiBlok.run()
akan memblok thread selamanya.
Ketika Timer
selesai, objek akan melakukan interupsi dengan memanggil interrupt()
.
Kemudian objek threadDiBlok
diset ke null
sehingga bisa diambil oleh
pemulung memori untuk dibersihkan.
sumber : http://java.lyracc.com/belajar/java-untuk-pemula/menghentikan-thread