Condivisione della tecnologia

한어Русский языкEnglishFrançaisIndonesianSanskrit日本語DeutschPortuguêsΕλληνικάespañolItalianoSuomalainenLatina

1. Utilizzo di base

• Supponiamo che esista uno scenario del genere:20 utenti acquistano 10 biglietti insieme。

1.1 Implementazione del codice senza blocco

public class TicketDemo {
   

    // 票总数
    private int ticketNum = 10;

    /**
     * 抢票
     */
    public void getTicket() {
   
        if (ticketNum <= 0) {
   
            return;
        }
        System.out.println(Thread.currentThread().getName() + " 抢到一张票，剩余：" + ticketNum);
        // 非原子性操作
        ticketNum--;
    }

    /**
     * 测试：20个人抢一张票
     */
    public static void main(String[] args) {
   
        TicketDemo ticketDemo = new TicketDemo();
        for (int i = 0; i < 20; i++) {
   
            new Thread(ticketDemo::getTicket).start();
        }
    }
}
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

Risultati di:

Puoi vedere che appare problema di ipervenduto , ci sono 10 biglietti in totale. Quando 20 thread prendono i biglietti insieme, sembra che 11 persone abbiano preso i biglietti. Questo perché se entrambi i thread superano il controllo if contemporaneamente.

Pertanto, dobbiamo bloccare l'operazione del ticket per garantire che solo un thread possa verificare ed eseguire la detrazione del ticket contemporaneamente.

1.2 Implementazione del codice di blocco

public class TicketDemo {
   

    // 锁
    private static Object lock = new Object();

    // 票总数
    private int ticketNum = 10;

    /**
     * 抢票
     */
    public void getTicket() {
   
        synchronized (lock) {
   
    
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16