Global true.b = 1                         ; переменная для вычного цикла
Global semaphore = CreateSemaphore()      ; объявление переменной semaphore, которая является семафором
Global mutex     = CreateMutex()          ; объявление переменной mutex, которая является мьютексом     

Structure messagebox
  sender.l                                ; номер потока, который отправляет сообщение
  recipient.l                             ; номер потока, которому нужно отпарвить сообщение
  message_body.s                          ; само сообщение
EndStructure
 
Global NewList queue.messagebox()        ; объявление списка queue, в который записываются сообщения 

Procedure send(sender_thread.l, recipient_thread.l, message.s)
  
  ; send - посылает сообщение заданному потоку
  ; sender_thread - какой поток отсылает сообщение
  ; recipient_thread - какому потоку отослать сообщение
  ; message - само сообщение
  
  LastElement(queue())                     ; переходим к последнему элементу в списке
  AddElement(queue())                      ; добавить новый элемент в список
   
  queue()\sender = sender_thread           ; пишем какой поток хочет отослать
  queue()\recipient = recipient_thread     ; пишем какому потоку хотим отправить сообщение
  queue()\message_body = message           ; само сообщение
EndProcedure

Procedure.s receive(recipient_message.l)
  
  ; receive - получет сообщение от другого потока
  ; recipient_message - номер потока, который хочет получить сообщение

  message.s = ""                           ; переменная для записи всех сообщений, которые пришли данному потоку
  
  ForEach queue()                         ; смотрим какие у нас данные в списке
    
    If queue()\recipient = recipient_message       ; если это сообщение направлено данному потоку
      ; записываем все сообщения, которые были отосланы этому потоку
      message = message + "поток " + Str(recipient_message) + " принял: " + queue()\message_body + " от потока " + Str(queue()\sender) + "; "  
      DeleteElement(queue())                             ; Удаление текущего элемента в списке
    EndIf
    
  Next

  ProcedureReturn message.s
EndProcedure

Procedure Thread(*number)
  
  counter.i = 0                                      ; переменная для данных (их отображение) 
  
  While true = 1 
    
    Delay(1000)
    send_of_receive.l = Random(1)                     ; здесь случаенно определяется, поток хочет послать, или принять сообщение
    
    If send_of_receive = 1                            ; если 1, значит отослать
      
      LockMutex(mutex)                                ; входим в критическую секцию, с помощью мьютекса
    
      send_thread.l = Random(3)                       ; узнаём какому потоку послать сообщение
      data_message.s = "message" + Str(counter)       ; присвоить этому элементу значение
      counter = counter + 1                           ; увеличиваем значение переменной, чтобы различать данные

      send(send_thread.l, *number, data_message.s)     ; отправить сообщение указанному потоку
      
      UnlockMutex(mutex)                              ; выходим из критической секции, с помощью мьютекса
      SignalSemaphore(semaphore)                      ; увеличиваем значение семафора
    Else                                              ; иначе получаем сообщение
      
      LockMutex(mutex)                                 ; входим в критическую секцию, с помощью мьютекса
      
      received_message.s = receive(*number)            ; получаем сообщения
      
      If Not received_message = ""                       ; если этому потоку ни кто сообщения не посылал, то ничего и не выводим
         Debug received_message
      EndIf
    
      UnlockMutex(mutex)                                   ; выходим из критической секции, с помощью мьютекса  
      WaitSemaphore(semaphore)                             ; уменьшаем значение семафора
    EndIf
    
  Wend 
EndProcedure

thread0 = CreateThread(@Thread(), 0)   ; создать поток thread1
thread1 = CreateThread(@Thread(), 1)   ; создать поток thread2
thread2 = CreateThread(@Thread(), 2)   ; создать поток thread3
thread3 = CreateThread(@Thread(), 3)   ; создать поток thread2

  
WaitThread(thread0)      
WaitThread(thread1)
WaitThread(thread2)
WaitThread(thread3)