Блог

Мне нужна библиотека ведения журнала для моего многопоточного приложения Tcl. Могу ли я использовать стандартный logger пакет? Если я могу, какие ограничения применяются в многопоточной среде?

Я хотел бы разделить службы ведения журнала между потоками, если это возможно.

Спасибо

Потоки Tcl не обмениваются данными (если вы явно не используете определенные средства из пакета Thread), а вместо этого обмениваются данными посредством передачи сообщений. Таким образом, кажется, что правильным решением было бы настроить выделенный поток «logger» и просто ставить в очередь сообщения о регистрации в нем из рабочих потоков.

В противном случае спорная точка, вероятно, будет где-то в ресурсе операционной системы, используемом регистратором для фактической записи данных.

Обновление Хорошо, вот рабочий набросок того, что я на самом деле предложил реализовать:

 package require Tcl 8.5
package require Thread

proc make_worker_thread {logger_id body} {
  set newbody [list set ::logger $logger_id]
  append newbody n {
    proc ::log {severity msg} {
      global logger
      thread::send $logger [list ::log $severity $msg]
    }
  } n $body
  thread::create $newbody
}

set logger [thread::create {
  package require logger

  proc log {severity msg} {
    puts "hey, that's it: ($severity) $msg"
  }

  puts "logger thread created: [thread::id]"

  thread::wait
}]

for {set i 0} {$i < 3} {incr i} {
  make_worker_thread $logger {
    proc post_msg {} {
      log notice "A message from [thread::id]"
        after 1000 ::post_msg
    }

    puts "worker thread created: [thread::id]"

    after 1000 ::post_msg

    thread::wait
  }
}

vwait forever
  

Этот код создает один поток регистратора и четыре рабочих потока, каждый из которых отправляет сообщение потоку регистратора один раз в секунду. Код выполняется до тех пор, пока не будет прерван вручную. Поток регистратора просто бесхитростно выводит сообщение, которое было передано на консоль, но, как уже упоминал кто-то еще в этом потоке, вы, вероятно, могли бы использовать пакет «logger» из Tcllib, если вам нужны такие необычные вещи, как средства.

Чтобы повторить мои доводы:

• Сам пакет logger, по-видимому, ничего не знает о потоковой передаче.
• Потоки Tcl хорошо разделены и обычно взаимодействуют посредством передачи сообщений.
• Следовательно, создайте поток для регистратора и научите рабочие потоки отправлять ему сообщения; следовательно, рабочие потоки не связаны с тем, как реализован регистратор.

P.S. В рабочих потоках вы можете использовать [thread::send -async ...] , чтобы сделать отправку сообщений журнала полностью асинхронной.

API ведения журнала для Tcl

Эта реализация потокобезопасна. Из-за общего назначения C-функциям не требуется tcl-интерпретатор.

Это немного зависит от того, чего вы хотите достичь с помощью многопоточного использования logger.

Если у вас просто есть вариант использования, чтобы не блокировать ваши рабочие потоки при записи сообщений журнала на диск, самый простой способ — использовать logger в обычном режиме и настроить простой logproc, который выполняет thread::send -async для некоторого потока ведения журнала (который сам может использовать logger с добавлениями для записи фактических файлов журнала) с вашим сообщением журнала (в основном, то, что было набросано в принятом ответе).

Если вы хотите использовать опцию loggers для отключения / включения ведения журнала для всей программы в разных потоках, вам нужно проделать немного больше работы, чтобы распространить изменения на уровне журнала на все потоки с помощью пользовательских lvlchangeproc.

Вот моя «многопоточная» оболочка для logger пакета:

 # replacement for logger::init procedure from logger package
proc ::mylogger::init { service } {
  set log [logger::init $service]

  foreach lvl [logger::levels] {
    interp alias {} log_to_file_$lvl {} ::mylogger::log $lvl $service
    ${log}::logproc $lvl log_to_file_$lvl
  }

  return $log
}

proc mylogger::server { } {
  set t [thread::create {

    proc log { level txt } {
        set msg "[[clock format [clock seconds] -format "%Y-%m-%dT%H:%M:%S"]]t$levelt$txt"
        puts stderr $msg
    }

    # enter to event loop
    thread::wait
  }]

  tsv::set measure-logger loggerThread $t
}

proc ::mylogger::log { level service txt } {
  set t [tsv::get measure-logger loggerThread]
  thread::send -async $t [list log $level "$servicet$txt"]
}

# EXAMPLE

# start logging thread
# should be called once from main application thread
::mylogger::server

# create logger
# may be called from any thread
set log [mylogger::init myservice]

# log a message
# may be called from the thread the "mylogger::init myservice" was called in
${log}::debug myservice "Hello, World!"

# wait a second
after 1000