Блог

Это программа покупки билетов, и когда билет равен 0, он отобразит «распродажа». Интересно, почему я не могу добавить sleep в функцию buyTicket и почему ticket будет отрицательным?

  func(t *Ticket) buyTicket() {
        if t.getSpareTicket() <= 0 {
            log.Print("sell out")
            return
        }
        t.mu.Lock()
        t.numTicket--
        time.Sleep(time.Microsecond)
        log.Printf("there are %d", t.numTicket)
        t.mu.Unlock()
    }
    
    func (t *Ticket) getSpareTicket() int{
        t.mu.Lock()
        defer t.mu.Unlock()
        return t.numTicket
    }
    
    
    func main() {
        buyer := amp;Ticket{}
        buyer.mu = sync.Mutex{}
        buyer.numTicket = 100
        for buyer.getSpareTicket() > 0 {
            //time.Sleep(time.Microsecond)
            go func() {
                log.Printf("number buy a ticket")
                buyer.buyTicket()
            }()
        }
    
        time.Sleep(time.Second * 2)
        //l := buyer.getSpareTicket()
        //fmt.Println(l)
    }
  

когда я добавляю time.sleep(time.microsecond) в функцию buyTicket, билет будет отрицательным, я хочу знать, почему это происходит?

Это результат:

 2020/11/15 15:36:00 there are 2
2020/11/15 15:36:00 there are 1
2020/11/15 15:36:00 there are 0
2020/11/15 15:36:00 there are -1
2020/11/15 15:36:00 there are -2
2020/11/15 15:36:00 there are -3
2020/11/15 15:36:00 there are -4
2020/11/15 15:36:00 there are -5
  

В программе есть несколько проблем:

1- Цикл for создает подпрограммы, в то время как количество запасных билетов не равно нулю. Это создаст много подпрограмм, поскольку они не будут выполняться немедленно и уменьшат количество билетов

2- В buyTicket вы проверяете, а затем покупаете. Другая подпрограмма может войти и сделать то же самое после того, как одна подпрограмма проверит, решит продолжить и купит билет.

Решение состоит в том, чтобы исправить buyTicket на блокировку при разблокировке входа при выходе и проверить количество билетов без вызова getSpareTicket, потому что getSpareTicket также блокирует тот же мьютекс, что приведет к взаимоблокировке.