#CLiMP#

This library is experimental. Your comments are very welcome.

##Examples##

Note: By default SLIME does not change *standard-output* and friends outside of the REPL. If you have any other threads which call format, write-string, etc. that output will be seen only in the *inferior-lisp* buffer or on the terminal, more often than not this is inconvenient. So, if you want to send output to SLIME's repl buffer, as opposed to *inferior-lisp*, set swank:*globally-redirect-io* to T.

Note that the value of this variable is only checked when swank accepts the connection so you should set it via ~/.swank.lisp. Otherwise you will need to call swank::globally-redirect-io-to-connection yourself, but you shouldn't do that unless you know what you're doing.

###Hello World###

(use-package :climp)

(defun hello-world (nthreads)
  (parallel (:number-of-threads nthreads)
    (format t "~&I'm number: ~a" thread-number)
    (once
      (format t "~&Number-of-threads: ~a" number-of-threads))))

###From sequential cycle to parallel cycle###

(use-package :climp)

(defun sequential-function (niterations)
  (dotimes (i niterations)
    (some-action i)))

(defun parallel-function (niterations)
  (parallel-dotimes (i niterations)
    (some-action i)))

###Private variables###

(use-package :climp)

(defun parallel-count-if-for-list (pred list nthreads)
  (let ((count 0))
    (parallel-dolist (obj list :number-of-threads nthreads
                               :vars ((private-count 0 (lambda (private-count)
                                                         (incf count private-count)))))
      (when (funcall pred obj)
        (incf private-count)))
    count))

###Sum of array elements using a variable reduction###

(use-package :climp)

(defun array-elements-sum (array nthreads)
  (let ((sum 0))
    (parallel-dotimes (i (array-total-size array) :number-of-threads nthreads
                                                  :vars ((:incf sum)))
      (declare (type fixnum i sum))
      (incf sum (aref array i)))
    sum))

###Defining of your own reductions###

(use-package :climp)

(define-reduction print (var &optional start-value )
 `(,var ,start-value #'print))
 
(parallel (:number-of-threads 4
           :vars ((:print test "Master thread")))
  (slave
    (setf test "Slave thread")))

###Defining of your own PARALLEL commands###

(use-package :climp)
(use-package :bt)
(use-package :alexandria)

(define-parallel-command critical (&rest body)
  (with-gensyms (lock)
   `(:vars ((,lock (make-lock)))
     :body (with-lock-held (,lock) ,@body))))