purebasic.info

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23

Procedure Thread(*value)
  A.l
  Repeat 
    A = X      ;хочу переменную "X" из основной программы постоянно считывать в переменную "А"  потока
    ;...код потока
    ;..................
    Y = A      ;для простоты пусть внутрипотоковая "А" постоянно копируется в переменную "Y", которая из основной программы
  ForEver
EndProcedure
;=========================================================================
CreateThread(@Thread(), 0)  ;Создаю и запускаю поток
If OpenConsole()  ;основная программа для теста
  X.l
  Y.l
  Repeat 
    Print("Введите цифру от 1 до 9 в переменную X: ")
    X = Asc(Input())
    If X=Asc("0"): CloseConsole(): End: EndIf  ;условие выхода из программы
    Delay(100)                                 ; просто задержка
    PrintN("возвращение числа из потока " + Chr(Y));нужно умудрится получить то же число что и ввели
    PrintN("Для выхода  введите '0', или прокатите через поток следующую цифру ...")
  ForEver
EndIf

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
33
34
35
36
37
38
39
40
41
42
43
44

Global Semaphore = CreateSemaphore()
Global Mutex     = CreateMutex()
Global NewList Queue()
 
Procedure Producer(Total)
 
  For i = 1 To Total
    Delay(Random(750) + 250)
    
    ; The queue access still needs a normal mutex lock to be thread-safe
    LockMutex(Mutex)
      LastElement(Queue())
      AddElement(Queue())
      Queue() = i
    UnlockMutex(Mutex)    
 
    ; Signal that there is a new queue element
    SignalSemaphore(Semaphore)
  Next i
    
EndProcedure
 
If CreateThread(@Producer(), 30)
 
  For i = 1 To 30  
    ; wait for one element to be available
    WaitSemaphore(Semaphore)
    
    ; display the queue state
    LockMutex(Mutex)
      Queue$ = "Queue:"
      ForEach Queue()
        Queue$ + " " + Str(Queue())
      Next Queue()
      Debug Queue$
    
      ; remove head element from the queue
      FirstElement(Queue())
      DeleteElement(Queue())
    UnlockMutex(Mutex)
    
  Next i
 
EndIf

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24

Global X.l, Y.l
 
Procedure Thread(*value)
  A.l
  Repeat 
    A = X      ;Хочу переменную "X" из основной программы постоянно считывать в переменную "А"  потока
               ;...код потока
               ;.............
               ;для простоты пусть внутрипотоковая "А" постоянно копируется в переменную "Y", которая из основной программы
    Y = A 
  ForEver
EndProcedure
CreateThread(@Thread(), 0)  ;Создаю и запускаю поток
If OpenConsole()            ;основная программа для теста
  
  Repeat 
    Print("Введите цифру от 1 до 9 в переменную X: ")
    X = Asc(Input())
    If X=0: CloseConsole(): End: EndIf  ;условие выхода из программы
    Delay(100)                                 ; просто задержка
    PrintN("возвращение числа из потока " + Chr(Y));нужно умудрится получить то же число что и ввели
    PrintN("Для выхода  введите '0', или прокатите через поток следующую цифру ...")
  ForEver
EndIf

1
2
3
4
5
6
7
8
9

 
   *paket=AllocateMemory(20)                       ;выделяем 20 байт оперативной памяти
    If ComRead(Hcom_CI5003,*paket,19)               ;читаем принятый пакет из порта в память
      For a=0 To 18                                            ;читаем побайтно пакет из памяти в массив приема
        RX_CI5003(a)=PeekC(*paket+a)
      Next a
    EndIf
    FreeMemory(*paket)                                ;освобождаем память
 

1
2
3
4
5
6
7
8
9
10
11

 
    NbDataToRead_Memograph = ComInputBufferCount(HCom_Memograph)     ;узнаём сколько байт пришло в буфер
      Global Dim RX_Memograph(NbDataToRead_Memograph-1)                      ;переопределяем массив приема
      *paketM=AllocateMemory(NbDataToRead_Memograph)                         ;выделяем NbDataToRead байт оперативной памяти
      If ComRead(HCom_Memograph,*paketM,NbDataToRead_Memograph)      ;читаем принятый пакет из порта в память
        For a=0 To NbDataToRead_Memograph-1                                        ;читаем побайтно пакет из памяти в массив приема
          RX_Memograph(a)=PeekC(*paketM+a)
        Next a
      EndIf
      FreeMemory(*paketM)                                                                   ;освобождаем память
 

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
33
34
35
36
37
38
39
40
41

 
  ;Отправляем запрос
    Restore zapros_CI5003                                                   ;помещаем указатель в начало zapros для команды Read
    x.c=0                                                                    ;переменная для хранения текущего байта из zapros
    For a=0 To 11                                                            ;цикл формирования пакета и отправки его в порт (байт за байтом)
      Read.c x                                                               ;читаем "атый" байт из раздела данных zapros_CI5003 в переменную x.c
       Select a
        Case 0 To 7,9,10                                                     ;формируемые посылки будут отличаться только адресом и CRC (8 и 11 быйты соответственно)
         TX_CI5003(a)=x
        Case 8 
          Select countCI5003
           Case 1
            TX_CI5003(a)=Adr1
           Case 2
            TX_CI5003(a)=Adr2
           Case 3
            TX_CI5003(a)=Adr3
          EndSelect    
        Case 11
         TX_CI5003(a)=CreateCRC_CI5003()  
       EndSelect  
      xxCI5003.c=TX_CI5003(a)  
      ;Debug xx
      WriteSerialPortData(#SerialPort_CI5003, @xxCI5003, 1)                   ;отправляем в порт "атый" байт
    Next a                                                                   ;следующий байт...
 
;Читаем ответ
    *paketCI5003=AllocateMemory(20)                                          ;выделяем 20 байт оперативной памяти RAM
    If ReadSerialPortData(#SerialPort_CI5003, *paketCI5003, 19)              ;читаем принятый пакет из порта в память RAM
      ;Debug Hex(PeekC(*paketCI5003+3))
      For a=0 To 18                                                          ;читаем побайтно пакет из памяти RAM в массив приема
        RX_CI5003(a)=PeekC(*paketCI5003+a)
      Next a
    EndIf
    FreeMemory(*paketCI5003)                                                 ;освобождаем память
 
  DataSection                                                          ;раздел данных (пакет запроса для прибора 1)
    zapros_CI5003:
    Data.c $FF, $FF, $FF, $82, $FF, $FF, $FF, $FF, $00, $01, $00, $83
  EndDataSection
 

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
33
34
35
36
37
38
39
40
41
42
43
44
45

 
;Отправляем запрос
    Restore zapros_Memograph                                             ;помещаем указатель в начало zapros для команды Read 
    x.c=0                                                                 ;переменная для хранения текущего байта из zapros_Memograph
    For a=0 To 12                                                        ;цикл формирования пакета и отправки его в порт побайтно
      Read.c x
      Select a
       Case 1                                                            ;2 и 3 байты формируют адрес прибора в ASCII
        TX_Memograph(a) = Asc(Str(AdrMemograph/10))
       Case 2
        TX_Memograph(a) = Asc(Str(AdrMemograph%10)) 
       Case 10                                                           ;10 байт - номер канала прибора в ASCII
        TX_Memograph(a) = Asc(Str(Channel_Memograph-1))
       Case 12                                                           ;12 байт - CRC
         TX_Memograph(a)=CreateCRC_Memograph()
       Default
         TX_Memograph(a)=x
      EndSelect 
      xxMemograph.c=TX_Memograph(a)  
      ;Debug Hex(xxMemograph)
      WriteSerialPortData(#SerialPort_Memograph, @xxMemograph, 1)
    Next a
 
;Читаем ответ
    NbDataToRead_Memograph = AvailableSerialPortInput(#SerialPort_Memograph)  ;узнаём сколько байт пришло в буфер порта (размер принятого пакета)
    ;Debug Str(NbDataToRead_Memograph)
    
    If NbDataToRead_Memograph>10                                         ;пакеты размером меньше 11 байт не рассматриваем 
      Global Dim RX_Memograph(NbDataToRead_Memograph-1)                 ;переопределяем массив приема (автоматически обнуляется)
      *paketM=AllocateMemory(NbDataToRead_Memograph)                     ;выделяем NbDataToRead байт оперативной памяти RAM
      
      If ReadSerialPortData(#SerialPort_Memograph, *paketM, NbDataToRead_Memograph)   ;читаем принятый пакет из порта в память RAM
        ;Debug Hex(PeekC(*paketM+NbDataToRead_Memograph-1))                ;нумерация ячеек памяти идёт с 0 до NbDataToRead-1
        For a=0 To NbDataToRead_Memograph-1                              ;читаем побайтно пакет из памяти RAM в массив приема
          RX_Memograph(a)=PeekC(*paketM+a)
        Next a
      EndIf
      FreeMemory(*paketM)                                                 ;освобождаем память
 
  DataSection                                                          ;раздел данных (пакет запроса для прибора 2)
    zapros_Memograph:
    Data.c $01, $30, $31, $02, $4D, $30, $41, $4E, $4C, $47, $30, $03, $4A
  EndDataSection
 
 

1
2
3
4
5
6
7
8

For i=0 To 11
  Debug PeekA(?zapros_CI5003+i)
Next i
 
DataSection
  zapros_CI5003:
  Data.a $FF, $FF, $FF, $82, $FF, $FF, $FF, $FF, $00, $01, $00, $83
EndDataSection