firejox

ch = Channel(Int32).new
done = Channel(Time::Span).new

count = (ARGV[0]? || 1000).to_i

4.times do
  spawn do
    delay = Time::Span::ZERO
    count.times do |i|

firejox

total_delay = Time::Span::ZERO
done = Channel(Time::Span).new

(ARGV[0]? || 1000).to_i.times do |i|
  ch = Channel(Int32).new

  501.times do |j|
    if j == 250
      spawn do
        delay = Time.measure do

firejox

ch1 = Channel(Int32).new
ch2 = Channel(Int32).new

500.times do 
  spawn do
    r = Random.new
    ch2.send(r.next_int)
  end
end

firejox

macro container_of(ptr, _type, member)
    {% if _type.resolve < Reference %}
        (({{ ptr }}).as(Void*) - offsetof({{ _type }}, {{ member }})).as({{ _type }})
    {% else %}
        (({{ ptr }}).as(Void*) - offsetof({{ _type }}, {{ member }})).as(Pointer({{ _type }}))
    {% end %}
end

struct StaticList
    @prev = uninitialized Pointer(StaticList)

firejox

Architecture:        x86_64
CPU op-mode(s):      32-bit, 64-bit
Byte Order:          Little Endian
Address sizes:       48 bits physical, 48 bits virtual
CPU(s):              2
On-line CPU(s) list: 0,1
Thread(s) per core:  1
Core(s) per socket:  2
Socket(s):           1
NUMA node(s):        1

firejox

#ifndef FIBFUZZYSHELLSORT_HPP
#define FIBFUZZYSHELLSORT_HPP

#include <limits>
#include "ShellSortTemplate.hpp"
#include "IntegralConstantArithmetic.hpp"

namespace FibFuzzyNS {
    using namespace IntegralConstantArithmetic;

firejox

function y = my_midpoint_method(f, y0, a, b, n)
    h = (b - a) / n
    y = 0:n
    y(0) = y0
    for i = 1:n
        y(i) = y(i - 1) + h * f(a + h*(i - 1) + h*0.5, y(i - 1) + 0.5*h*f(a + h*(i - 1), y(i - 1)))
    end
end

firejox

# AMD Athlon(tm) II X2 270 Processor
# Arch Linux x86_64
# gcc (GCC) 6.2.1 20160830
# Crystal 0.19.4 (2016-10-07)
Crystal
181
== 1.22s, 4.4Mb ==
Crystal with new channel
181
== 2.39s, 16.7Mb ==

firejox

Bug: called create_llvm_type for T
0x752ed7: *CallStack::unwind:Array(Pointer(Void)) at ??
0x752e6a: *CallStack#initialize:Array(Pointer(Void)) at ??
0x752e3a: *CallStack::new:CallStack at ??
0x73051e: *raise<Exception>:NoReturn at ??
0x73050e: ??? at ??
0x13e02d5: ??? at ??
0x13dc0eb: ??? at ??
0x13dc671: *Crystal::LLVMTyper#llvm_embedded_type<Crystal::Type+, Bool>:LLVM::Type at ??
0x13de76f: *Crystal::LLVMTyper#create_llvm_struct_type<(Crystal::GenericClassInstanceType+ | Crystal::GenericClassType+ | Crystal::GenericModuleInstanceType | Crystal::GenericModuleType | Crystal::NonGenericClassType | Crystal::NonGenericModuleType+ | Crystal::VirtualType), Bool>:LLVM::Type at ??

firejox

Error in line 1: while requiring "./channel_spec.cr"

in channel_spec.cr:122: instantiating 'AsyncAwait::Channel(T):Class#select_with_csp()'

    AAChannel.select_with_csp do |x|
              ^~~~~~~~~~~~~~~

in /home/firejox/develop/async_await/src/async_await/channel.cr:290: instantiating 'AsyncAwait::Channel(T):Class#select()'

      self.select do |action|