thread-party

easy thread pool with package bordeaux-threads and lparallel.queue, has fashionable symbol name

load-package

(load "~/quicklisp/setup.lisp")

(ql:quickload :thread-party)

party-plan

;plan the number of threads in the thread pool
(setf thread-party:*party-plan* 6) ;threads count 6

;or according to the multiple of cpu core count
(thread-party:make-plan 2) ;thread-count = 2 * your-cpu-core-number 

start-party

;create the thread pool
(thread-party:start-party) 

;or use main function
(thread-party:main)

take-party

;send your message to the thread pool
;the default theme will evaluate the expression in the message

;;numerical value
(thread-party:send-message '(* 1 2))

;;local value
(let ((a 1))
    (thread-party:send-message `(* ,a 2)))

;;use in function
(defun the-multiplication (a b)
    (thread-party:send-message `(* ,a ,b)))
    
(the-multiplication 1 2)

party-theme

;default-theme will eval the form in the message
;you can define your function handle the message in thread-pool
;all threads in pool is running this function

;;theme-example-list-length
(defun list-length (the-message thread-number)
    (let ((the-value (length the-message))) ;the length of message
        (log:info "~%<~A>~t~A~%" thread-number the-value)))
        
(thread-party:set-theme #'list-length)

(thread-party:send-message '(* 1 2))

;;theme-example-reverse-string
(defun reverse-string (the-message thread-number)
    (log:info "~%~A~t~A~%" thread-number (reverse the-message)))
  
(thread-party:set-theme #'reverse-string)

(thread-party:send-message "hi")
(thread-party:send-message "lisp")

;;theme-example-number-addition
(setf message-list '(100 200 300))
(setf value-list nil)

(defun add-hundred (the-message thread-number)
    (push (list :thread thread-number :message the-message :vaule (+ 100 the-message)) 
          value-list))

(thread-party:set-theme #'add-hundred)

(mapcar (lambda (a) (thread-party:send-message a)) message-list)

value-list

;;define your more powerful function
;;;for example a function to determine whether it is a prime number
(defun a (b)
  (if (<= b 1)
      nil
      (c b (1- b))))

(defun c (d e)
  (if (= e 1)
      (progn (push d f)
             (values d t))
      (if (= 0 (mod d e))
          nil
          (c d (1- e)))))
          
;;;default-theme-example
(thread-party:set-theme #'thread-party:default-theme)

(setf f nil)

(loop for i from 1 to 100 do
    (thread-party:send-message `(a ,i)))

(symbol-value 'f)

;;;user-theme-example
(defun a (b thread-number) ;redefine function #'a that take the parameter
  (if (<= b 1)
      nil
      (c b (1- b))))

(thread-party:set-theme #'a)

(setf f nil)

(loop for i from 1 to 100 do
    (thread-party:send-message i))

(symbol-value 'f)

thread-list

;show all the threads 
(thread-party:list-thread)

;show the threads in thread-pool
thread-party:*party-list*

;check thread count
(equal (length thread-party:*party-list*) thread-party:*party-plan*)

close-party

(thread-party:close-party)

div-party

;when you want to hold more than one party, you can use the next part
(defun party-theme-listp (the-message thread-number)
    (let ((the-value (listp the-message)))
        (log:info "~%~A~t~A~t~A~%" thread-number the-message the-value)))

(thread-party:plan-party 'fashion-list-party :party-plan 6 :party-theme #'party-theme-listp)

(thread-party:hold-party fashion-list-party)

(thread-party:take-party fashion-list-party `(nil))

(thread-party:sure-party fashion-list-party #'thread-party:default-theme)

(thread-party:take-party fashion-list-party `(nil))

(thread-party:shut-party fashion-list-party)

usage

;;parameter
;thread-party::*party-queue*
;thread-party::*party-list*
;;function
;thread-party::make-plan core-multiple
;thread-party::set-theme function-symbol
;thread-party::send-message message-form
;thread-party::start-party
;thread-party::close-party
;thread-party::list-thread
;thread-party::main
;thread-party::plan-party party-symbol-quote
;thread-party::hold-party party-symbol
;thread-party::sure-party party-symbol party-theme
;thread-party::take-party party-symbol message-form
;thread-party::shut-party party-symbol 

more

;https://lparallel.org/api/queues/
;https://sionescu.github.io/bordeaux-threads/
;https://github.com/7max/log4cl
;https://github.com/muyinliu/cl-cpus
;https://lispcookbook.github.io/cl-cookbook/