Maison >Java >javaDidacticiel >Les principes et scénarios d'utilisation de Synchronized en Java et l'analyse de l'utilisation et des différences de l'interface Callable
Les principes et scénarios d'utilisation de Synchronized en Java et l'analyse de l'utilisation et des différences de l'interface Callable
- WBOYavant
- 2023-04-21 08:04:071154parcourir
1. Fonctionnalités de base
1. Cela commence par un verrouillage optimiste si les conflits de verrouillage sont fréquents, il sera converti en verrouillage pessimiste
2. Cela commence par une mise en œuvre légère du verrouillage. longtemps, longtemps, il est converti en un verrou lourd.
3. La stratégie de verrouillage rotatif qui est la plus probablement utilisée lors de la mise en œuvre de verrous légers
4 C'est un verrou injuste
5.
6. Pas un verrou en lecture-écriture2. Processus de verrouillageJVM divise les verrous synchronisés en états de verrouillage sans verrouillage, biaisés, légers et lourds. Il sera mis à niveau séquentiellement en fonction de la situation.
StringBuffer sb = new StringBuffer();
sb.append("a");
sb.append("b");
sb.append("c");
sb.append("d");À l'heure actuelle, chaque appel d'ajout impliquera le verrouillage et le déverrouillage. un seul thread, alors ces opérations de verrouillage et de déverrouillage sont inutiles et gaspillées. Une certaine surcharge de ressources. Leader, attribuez des tâches de travail aux subordonnésMéthode 1 :Appelez, donnez la tâche 1, raccrochez.
Appelez, donnez la tâche 2, raccrochez.
Appelez, donnez la tâche 3, raccrochez
Méthode 2 :
Appelez, donnez la tâche 1, la tâche 2, la tâche 3, raccrochez le téléphone
4. Interface appelable
Qu'est-ce que Callable ?
Callable est une interface qui équivaut à encapsuler une "valeur de retour" dans un. thread. Il est pratique pour les programmeurs de calculer les résultats en utilisant le multi-threading.
Callable 和 Runnable 相对, 都是描述一个 "任务". Callable 描述的是带有返回值的任务, Runnable 描述的是不带返回值的任务.Callable 通常需要搭配 FutureTask 来使用. FutureTask 用来保存 Callable 的返回结果. 因为 Callable 往往是在另一个线程中执行的, 啥时候执行完并不确定. FutureTask 就可以负责这个等待结果出来的工作.
代码示例: 创建线程计算 1 + 2 + 3 + ... + 1000, 不使用 Callable 版本
public class Text {
static class Result{
public int sum = 0;
public Object locker = new Object();
}
public static void main(String[] args) throws InterruptedException {
Result result = new Result();
Thread t = new Thread(){
@Override
public void run() {
int sum = 0;
for (int i = 0; i <=10000; i++){
sum += i;
}
result.sum = sum;
synchronized (result.locker){
result.locker.notify();
}
}
};
t.start();
synchronized (result.locker){
while (result.sum == 0){
result.locker.wait();
}
}
System.out.println(result.sum);
}
}代码示例: 创建线程计算 1 + 2 + 3 + ... + 1000, 使用 Callable 版本
import java.util.concurrent.Callable;
import java.util.concurrent.ExecutionException;
import java.util.concurrent.FutureTask;
public class Text1 {
public static void main(String[] args) throws ExecutionException, InterruptedException {
Callable<Integer> callable = new Callable<Integer>() {
@Override
public Integer call() throws Exception {
int sum = 0;
for (int i = 0; i <=1000; i++){
sum += i;
}
return sum;
}
};
//由于Thread不能直接传一个callable实例，就需要一个辅助类来包装
FutureTask<Integer> futureTask = new FutureTask<>(callable);
Thread t = new Thread(futureTask);
t.start();
//尝试在主线程获取结果
//如果FutureTask中的结果还没生成。此时就会阻塞等待
//一直等到最终的线程把这个结果算出来，get返回
Integer result = futureTask.get();
System.out.println(result);
}
}Ce qui précède est le contenu détaillé de. pour plus d'informations, suivez d'autres articles connexes sur le site Web de PHP en chinois!
Déclaration：
Cet article est reproduit dans:. en cas de violation, veuillez contacter admin@php.cn Supprimer
Article précédent：Comment utiliser @SuppressWarnings en Java ?Article suivant：Comment utiliser @SuppressWarnings en Java ?