#Java - Code Snippets for '#Threads' - 5 code snippet(s) found |
|
Sample 1. Singleton Class ( using private constructor , object initialization using static method, doubly checked , thread safe, synchronized , volatile reference ) | |
|
class Singleton {
private static volatile Singleton instance = null;
private Singleton(){}
public static Singleton getInstance() {
if (instance == null) {
synchronized(Singleton.class) {
if (instance== null)
instance = new Singleton();
}
}
return instance;
}
}
|
|
Like Feedback singleton singleton class volatile private constructor object initialization using static method doubly checked thread safe synchronized block using class level lock synchronized synchronized block class level lock object initialization using getInstance |
|
|
Sample 2. Write a program to show thread usage in Java by implementing runnable interface | |
|
public class MyClass {
static class MyThreadClass implements Runnable{
public void start() {
Thread t = new Thread(this,"threadName");
t.start();
}
@Override
public void run() {
System.out.println("Hello");
try {
Thread.sleep(1000);
System.out.println("Hello Again");
} catch (InterruptedException e) {
e.printStackTrace();
}
}
}
public static void main(String[] args){
MyThreadClass myThreadClass = new MyThreadClass();
myThreadClass.start();
MyThreadClass myThreadClass2 = new MyThreadClass();
myThreadClass2.start();
}
}
|
|
Like Feedback Threads runnable interface |
|
|
Sample 3. Retry in case of exception | |
|
public static final int NUMBER_OF_RETRIES = 5;
try {
// do something
} catch (Exception e) {
int count;
for (count = 1; count <= NUMBER_OF_RETRIES; count++) {
Thread.sleep(5000);
} catch (InterruptedException e1) {
try {
// do something again
break;
} catch (Exception ex) {
}
}
|
|
Like Feedback exception handling exception Retry in case of exception for loop for Thread.sleep InterruptedException |
|
|
Sample 4. Clear Map entries after expiration time using Apache commons PassiveExpiringMap | |
|
PassiveExpiringMap<String,String> cache = new PassiveExpiringMap<String,String>(1,TimeUnit.SECONDS); // Expiration time of 1 sec
cache.put("Key1", "Value1");
System.out.println(cache.containsKey("Key1")); // prints true
Thread.sleep(1000);
System.out.println(cache.containsKey("Key1")); // prints false
|
|
Like Feedback Clear Map entries after expiration PassiveExpiringMap map apache commons TimeUnit.SECONDS Thread.sleep |
|
|
|
Sample 5. Write a Program to show Java thread usage by extending Thread class | |
|
public class MyClass {
static class MyThreadClass extends Thread{
@Override
public void run() {
System.out.println("Hello");
try {
Thread.sleep(1000);
System.out.println("Hello Again");
} catch (InterruptedException e) {
e.printStackTrace();
}
}
}
public static void main(String[] args){
MyThreadClass myThreadClass = new MyThreadClass();
myThreadClass.start();
MyThreadClass myThreadClass2 = new MyThreadClass();
myThreadClass2.start();
}
}
|
|
Like Feedback Threads Thread class |
|
|