ysbaddaden

Crystal MTs (Multi Threaded schedulers)

Goals:

• developers must only care about fibers and channels;
• crystal runtime should start 1 upto N threads;
• each thread can take & resume any fiber in the loop;
• channels as user-code sync primitives;
• also propose fiber-aware mutex/monitors;
• additional sync primitives (e.g. IO events, ...)

ysbaddaden

require "./syslog"

syslog = Syslog.new
syslog.info "bla bla bla"

# $ tail -n1 /var/log/syslog
# Aug 18 00:55:05 xps crystal-run-syslog.tmp[27911]: bla bla bla

ysbaddaden

# Requires https://github.com/ysbaddaden/sdl.cr
require "sdl"

# Depends on the Crystal::Hasher implementation.
# Adjust to match the type of `"".hash`
alias HashType = UInt64

word_count = 0
maximum = 0
collisions = 0

ysbaddaden

diff --git a/src/exception.cr b/src/exception.cr
index b9bdc8a..c583f0b 100644
--- a/src/exception.cr
+++ b/src/exception.cr
@@ -44,9 +44,21 @@ struct CallStack
     callstack = [] of Void*
     backtrace_fn = ->(context : LibUnwind::Context, data : Void*) do
       bt = data.as(typeof(callstack))
-      ip = Pointer(Void).new(LibUnwind.get_ip(context))
+

ysbaddaden

# # Asynchronous DNS resolver for Crystal (sort of)
#
# It consists on starting a thread that will run the blocking `getaddrinfo`
# syscall, thus allowing the main thread —the one running the event loop— to not
# stop while resolving domains, which can take from milliseconds to seconds.
# Communication with the thread is achieved through a socket pair, one for the
# main thread, and one for the resolver thread. Since we rely on socket, the
# event-loop will pause or resume fibers accordingly to messages sent or
# received from the socket.
#

ysbaddaden

# Benchmark run with Crystal 0.17.3 (LLVM 3.6) on "Intel Core i7-4712HQ CPU @ 2.30GHz" CPU

Brooklin (block)
haversine: 0.144098
     sqrt: 0.19007 (+31.904%)
 spheroid: 0.144098 (+1.59146e-09%)
ellipsoid: 0.188279 (+30.6604%)

Paris -> Marseille
haversine: 660.815

ysbaddaden

abandoned
able
absolute
adorable
adventurous
academic
acceptable
acclaimed
accomplished
accurate

ysbaddaden

diff --git a/src/thread/lib_pthread.cr b/src/thread/lib_pthread.cr
index 5094260..96f2530 100644
--- a/src/thread/lib_pthread.cr
+++ b/src/thread/lib_pthread.cr
@@ -17,6 +17,7 @@ lib LibPThread
 
   fun create = pthread_create(thread : Thread*, attr : Void*, start : Void* ->, arg : Void*) : Int32
   fun exit = pthread_exit(value : Void*)
+  fun yield = pthread_yield() : Int32
   fun join = pthread_join(thread : Thread, value : Void**) : Int32

ysbaddaden

Program received signal SIGPIPE, Broken pipe.

Program received signal SIGSEGV, Segmentation fault.
[Switching to Thread 0x7fffcd7f2700 (LWP 9702)]
0x0000000000000001 in ?? ()

(gdb) bt
#1  0x0000000000418491 in *Signal::handler<Int32>:(Nil | Void) () at /home/github/crystal/src/signal.cr:57
#2  <signal handler called>
#3  0x00007ffff772135d in write () at ../sysdeps/unix/syscall-template.S:81

ysbaddaden

FXHEADER:100
DATA:OFXSGML
VERSION:102
SECURITY:NONE
ENCODING:USASCII
CHARSET:1252
COMPRESSION:NONE
OLDFILEUID:NONE
NEWFILEUID:NONE