Repository navigation
Expand file tree
/
Copy pathDriver_2.java
More file actions
53 lines (38 loc) · 1.46 KB
/
Copy pathDriver_2.java
File metadata and controls
53 lines (38 loc) · 1.46 KB
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
import java.util.concurrent.Callable;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
import java.util.concurrent.Future;
//// Thread Implementation using Callable (It returns object through Future which stores the value.)
public class Driver_2 {
static final int MAX_T = 100; // pool of threads inorder to implement Multithreading.
public static void main(String abc[]) {
Callable<String> r1 = new Thread_2();
ExecutorService pool = Executors.newFixedThreadPool(MAX_T); //Executor Service - Capable of executing tasks concurrently in the background.
for (int i=0;i<100;i++){
try {
Future<String> session_id = pool.submit(r1); //Thread is submitted to get executed.
String value = session_id.get(); // Callable returns value which is fetched through get method of Future.
System.out.println("Value is "+value);
}
catch(Exception e){
e.printStackTrace();
}
}
}
}
class Thread_2 implements Callable<String> {
private String name;
String digest;
public Thread_2()
{
}
public String call ()
{
try {
digest = "hello";
} catch (Exception e) {
e.printStackTrace();
}
return digest; //Value of thread execution s returned.
}
}