Блог

В одном из сообщений в блоге Тимми Хосе на https://z0ltan.wordpress.com/2016/09/02/basic-concurrency-and-parallelism-in-common-lisp-part-3-concurrency-using-bordeaux-and-sbcl-threads/ он приводит пример неправильного способа печати на верхний уровень изнутри потока (используя в качестве примера потоки Bordeaux, хотя я использую Lparallel):

 (defun print-message-top-level-wrong ()
  (bt:make-thread
    (lambda ()
      (format *standard-output* "Hello from thread!")))
  nil)

(print-message-top-level-wrong) -> NIL
  

Объяснение заключается в том, что «Тот же код выполнялся бы нормально, если бы мы не запускали его в отдельном потоке. Что происходит, так это то, что у каждого потока есть свой собственный стек, в котором переменные восстанавливаются. В этом случае, даже для *standard-output* , которая, будучи глобальной переменной, как мы предполагаем, должна быть доступна для всех потоков, является отскоком внутри каждого потока!»

И это именно то, что происходит, если функция выполняется в Allegro CL. Однако в SBCL функция действительно печатает предполагаемый результат на терминале. Означает ли это, что *standard-output* не выполняется восстановление в SBCL? В общем, существует ли кроссплатформенный способ печати в *standard-output* изнутри потока?

В многопоточной ситуации печать на терминал обычно должна быть скоординирована, чтобы избежать потенциальной печати из нескольких потоков одновременно. Но, похоже, нет никаких функций, таких как atomic-format или atomic-print доступных. Есть ли простой способ избежать помех при печати при наличии нескольких потоков (при условии, что блокировки / мьютексы слишком дороги для использования для каждой отдельной операции печати)?

Если у вас действительно есть глобальная привязка (привязка в глобальной среде), она действительно работает для всех потоков; смотрите документацию для bt:make-thread. Только динамические (повторные) привязки являются локальными для потока. Реализации отличаются тем, как / когда они связывают эти потоки; иногда привязка, которая фактически действует для пользовательских программ, является глобальной, иногда нет.

Мне нравится использовать какую-то очередь или канал для координации вывода, где это необходимо; Я еще не сталкивался с ситуациями, когда накладные расходы на блокировку были чрезмерно высокими.

Возможно, вы могли бы попробовать что-то с оптимистичной блокировкой, но я не знаю, что было сделано для этого по библиотекам (в некоторых реализациях Lisp есть операции CAS, которые можно использовать). Это должно быть ортогонально используемой библиотеке параллелизма.

РЕДАКТИРОВАТЬ: Только что найдено в руководстве по SBCL: sb-concurrency имеет очереди и почтовые ящики без блокировки.