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

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)                           ; код отдельного потока (всего их 4)
  
  counter.i = 0                                      ; переменная для данных (их отображение) 
  While true = 1 
    Delay(1000)
    
    send_of_receive.l = Random(1)                    ; поток узнаёт, отправить ли сообщение (1), или принять (0)

    If send_of_receive = 1                           ; если 1, значит отослать
      
      LockMutex(mutex)                               ; входим в критическую секцию, с помощью мьютекса
      
      While true = 1                                ; в цикле поток узнаёт, какому потоку отправить сообщение
        send_thread.l = Random(3)                    ; но поток не может послать сам себе сообщение
        If Not send_thread = *number
          Break
        EndIf
      Wend    

      data_message.s = "message" + Str(counter)      ; формируем сообщение для отправки
      counter = counter + 1                          ; увеличиваем значение переменной, чтобы различать сообщения

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

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

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

AddSysTrayIcon(25, WindowID(#Window_0), ExtractIcon_(0,ProgramFilename(),0))

RunProgramAtStartup(1,1,"Abracadabra","c:\windows\regedit.exe") ; Add to Startup
DelProgramAtStartup(1,1,"Abracadabra") ; Remove from Startup

;{- Enumerations / DataSections
;{ Windows
Enumeration
  #Window_0
EndEnumeration
;}
;{ Gadgets
Enumeration
  #Editor_1
  #Button_2
EndEnumeration
;}
Define.l Event, EventWindow, EventGadget, EventType, EventMenu
;}
Procedure OpenWindow_Window_0()
  If OpenWindow(#Window_0, 455, 62, 400, 400, "Window_0", #PB_Window_SystemMenu|#PB_Window_SizeGadget|#PB_Window_MinimizeGadget|#PB_Window_TitleBar)
   
      EditorGadget(#Editor_1, 20, 85, 345, 210)
      ButtonGadget(#Button_2, 35, 15, 75, 30, "Gadget_2")
   
  EndIf
EndProcedure

OpenWindow_Window_0()

;{- Event loop
Repeat
  Event = WaitWindowEvent()
  Select Event
    ; ///////////////////
    Case #PB_Event_Gadget
      EventGadget = EventGadget()
      EventType = EventType()
      If EventGadget = #Editor_1
      ElseIf EventGadget = #Button_2
        File$ = OpenFileRequester("","C:/","Text (*.txt)|*.txt;*.bat|PureBasic (*.pb)|*.pb|All files (*.*)|*.*",0)
        If File$ 
          If ReadFile(0, File$) 
      Size = Lof(0) 
      *Text = AllocateMemory(Size) 
      If  *Text
        ReadData(0,  *Text, Size)  
        
      EndIf
      CloseFile(0)
      SetGadgetText(#Editor_1,PeekS(*Text))
    EndIf

      EndIf
      EndIf
    ; ////////////////////////
    Case #PB_Event_CloseWindow
      EventWindow = EventWindow()
      If EventWindow = #Window_0
        CloseWindow(#Window_0)
        Break
      EndIf
  EndSelect
ForEver
;
;}