-
Notifications
You must be signed in to change notification settings - Fork 3
Expand file tree
/
Copy pathStructuredConcurrencyExample.java
More file actions
74 lines (64 loc) · 2.99 KB
/
Copy pathStructuredConcurrencyExample.java
File metadata and controls
74 lines (64 loc) · 2.99 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
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
/**
* Copyright (c) 2024 Araf Karsh Hamid
* Permission is hereby granted, free of charge, to any person obtaining a copy
* of this software and associated documentation files (the "Software"), to deal
* in the Software without restriction, including without limitation the rights
* to use, copy, modify, merge, publish, distribute, sublicense, and/or sell
* copies of the Software, and to permit persons to whom the Software is
* furnished to do so, subject to the following conditions:
* THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR
* IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY,
* FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE
* AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER
* LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM,
* OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN
* THE SOFTWARE.
* This program and the accompanying materials are dual-licensed under
* either the terms of the Eclipse Public License v1.0 as published by
* the Eclipse Foundation
* or (per the licensee's choosing)
* under the terms of the Apache 2 License version 2.0
* as published by the Apache Software Foundation.
*/
package java19;
import java.util.concurrent.ExecutionException;
import java.util.concurrent.StructuredTaskScope;
import static java.lang.System.out;
import static java.lang.Thread.*;
/**
* JEP 428: Structured Concurrency (Incubator)
*
* Structured concurrency allows tasks to be managed collectively, simplifying error handling
* and cancellation.
*
* @author: Araf Karsh Hamid
* @version:
* @date:
*/
public class StructuredConcurrencyExample {
public static void main(String[] args) throws InterruptedException, ExecutionException {
// Java 19
out.println("JAVA 19 >>>>>--------------------------------------------------------");
try (var scope = new StructuredTaskScope.ShutdownOnFailure()) {
out.println(">> Starting Task 1");
StructuredTaskScope.Subtask<String> future1 = scope.fork(() -> {
sleep(1000);
out.println(" Task 1 Completed");
return "Task 1 completed";
});
out.println(">> Starting Task 2");
StructuredTaskScope.Subtask<String> future2 = scope.fork(() -> {
sleep(2000);
out.println(" Task 2 completed");
return "Task 2 completed";
});
out.println(">> Waiting for All tasks to completed");
scope.join(); // Wait for all tasks to complete
out.println(">> Throws Exception if a task is failed!");
scope.throwIfFailed(); // Throw if any tasks failed
out.println(">> Waiting for Final Results.......");
System.out.println(">> RESULT 1 = "+future1.get());
System.out.println(">> RESULT 2 = "+future2.get());
}
}
}