Stack Overflow
Stack Overflow

Questions tagged [retlang]

Retlang is a high performance C# threading library (like Jetlang in Java). The library is intended for use in message based concurrency similar to event based actors in Scala. The library does not provide remote messaging capabilities. It is designed specifically for high performance in-memory messaging.

Retlang is a high performance C# threading library (see Jetlang for a version in Java). The library is intended for use in message based concurrency similar to event based actors in Scala. The library does not provide remote messaging capabilities. It is designed specifically for high performance in-memory messaging.

Source and information: https://code.google.com/p/retlang/

6 questions
3
votes
0 answers

Up-to-date Retlang examples

All Retlang examples/tutorials I can find on the web seem to be quite old:…
Alexey Romanov
  • 167,066
  • 35
  • 309
  • 487
2
votes
7 answers

Message-based multithreading or Thread Pool for a short and uncommon action?

I'm currently using Retlang for message-based multithreading in .NET, which is a great library. I've got no explicit locks anymore, every thread is doing its own business, managing its part of the application and communicating with other threads via…
Julien Lebosquain
  • 40,639
  • 8
  • 105
  • 117
1
vote
1 answer

Retlang: What is the best way to unsubscribe from a channel?

I'm not sure what is the best way to unsubscribe from a channel when using Retlang. When you subscribe by calling ISubscriber::Subscribe(...) you are returned an IUnsubscriber. This interface has no methods. Going up a level, IChannel also…
TrickyFishy
  • 43
  • 1
  • 4
1
vote
2 answers

Bounded Queue scenario

I need to implement a producer/consumer bounded queue, multiple consumers against a single producer. I have a push function that adds an item to the queue and then checks for maxsize. If we have reached it return false, in every other case return…
lboregard
  • 33
  • 3
1
vote
0 answers

Multiple publishers sending concurrent messages to a single subscriber in Retlang?

I need to build an application where some number of instances of an object are generating "pulses", concurrently. (Essentially this just means that they are incrementing a counter.) I also need to track the total counters for each object. Also,…
Justin Lang
  • 591
  • 1
  • 3
  • 17
0
votes
1 answer

Channel input prioritization in Retlang

How can channel input be handled in a prioritized fashion? Is there anything equivalent to Scala's "reactWithin(0) { ... case TIMEOUT }" construct?
anthony
  • 40,424
  • 5
  • 55
  • 128