ChillDev Commons Concurrent: concurrent processing skills in the Java class library
ChillDev Commons Concurrent: concurrent processing skills in the Java class library
In concurrent programming, abnormal treatment is a very important part.When multiple threads access shared resources at the same time, various abnormalities may occur.In order to ensure the stability and reliability of the program, we need to perform appropriate abnormal treatment.
ChillDev Commons Concurrent is a powerful Java class library that provides many convenient ways to handle abnormalities in concurrent programming.This article will introduce some concurrent processing techniques provided by ChillDev Commons Concurrent and provide corresponding Java code examples.
1. Use Retryer -Review function
Retryer is a very useful class in ChillDev Commons Concurrent, which can help us try it out when there is abnormal abnormality.Through Retryer, we can set up the number of retry, retry interval, and abnormal types to be captured.The following is an example using retryer to retry:
import pl.chilldev.commons.concurrent.retry.Retryer;
public class RetryExample {
public static void main(String[] args) {
Retryer retryer = new Retryer.Builder()
.retryOn(IOException.class)
.withMaxAttempts(3)
.withfixedbackoff (1000) // Repeat interval for 1 second
.build();
try {
retryer.call(() -> {
// Visit sharing resources, IOEXCEPTION may appear
// ...
return null;
});
} catch (Exception e) {
// Treatment abnormalities
// ...
}
}
}
In the above example, we created a Retryer, set up the maximum number of retries, the trial interval of 1 second, and specified that the abnormal type to be captured was IOEXception.In TRY blocks, we use the Retryer's call method to execute code blocks accessing shared resources. If IOEXCEPTION appears, it will be retrieved until the maximum number of retries is reached.
2. Use ResilientProcessor -an exception processor
ResilientProcessor is another useful class in ChillDev Commons Concurrent. It can help us handle abnormalities and ensure the normal operation of the program.The following is an example of an exception processing using ResilientProcessor for abnormal processing:
import pl.chilldev.commons.concurrent.resilience.ResilientProcessor;
public class ResilientProcessorExample {
public static void main(String[] args) {
ResilientProcessor<String, String> processor = new ResilientProcessor<>(
input -> {
// Visit sharing resources, there may be abnormalities
// ...
return null;
},
throwable -> {
// Treatment abnormalities
// ...
Return "to handle abnormal results"; // optional
}
);
try {
String result = processor.process ("input parameter");
// Treat the normal results
// ...
} catch (Exception e) {
// Treatment abnormalities
// ...
}
}
}
In the above example, we created a ResilientProcessor and provided a lambda expression to deal with the abnormalities of access to the shared resource.In the Lambda expression, we can perform abnormal treatment according to the specific situation, and we can also choose to return to the results of abnormalities.Then, in the TRY block, we use the PROCESS method of ResilientProcessor to perform access to shared resources and process normal results and abnormal conditions.
When using ChillDev Commons Concurrent, we can choose appropriate abnormal processing skills according to specific needs and scenes.Whether using Retryer to retry or using ResilientProcessor for abnormal processing, it can help us better deal with abnormal conditions in concurrent programming to ensure the stability and reliability of the program.
Through the above examples, we can see that ChillDev Commons Concurrent provides a simple and flexible way to handle concurrent abnormalities, and can be customized according to its own needs.In actual development, we should choose appropriate abnormal processing skills based on specific conditions, and combine our own business logic for reasonable abnormal treatment.In this way, we can write more robust and reliable concurrency procedures.
I hope this article will help you understand the complicated processing skills in ChillDev Commons Concurrent.thanks for reading!
