LeonHartley / Coerce-rs, Hacker News

Coerce-rs is an asynchronous (async / await) Actor runtime for Rust. It allows for extremely simple yet powerful actor-based multithreaded application development.

async / await Actors

An actor is just another word for a unit of computation. It can have mutable state, it can receive messages and perform actions. One caveat though .. It can only do one thing at a time. This can be useful because it can alleviate the need for thread synchronization, usually achieved by locking (using

Mutex

,RwLocketc).************How is this achieved in Coerce?

Coerce uses Tokio’s MPSC channels (tokio :: sync :: mpsc :: channel), every actor created spawns a task listening to messages from aReceiver, handling and awaiting the result of the message. Every reference (ActorRef(holds aSender where A: Handler, which can be cloned.

Actors can be stopped and actor references can be retrieved by ID (currentlyUuid) from anywhere in your application. Actors are automatically dropped (andStopped) when all references are dropped.

Example

************** (struct) ****************************************** EchoActor
{ }  # [async_trait]implActor for**************** (EchoActor********************** {}pubstructEchoMessage
String
);impl
Message
for**************** (EchoMessage********************** {     
type
Result=String; }  # [async_trait]impl
Handler ************************ for
EchoActor{     
async
fn
handle
self (*************************,         message: EchoMessage,         _ctx:  &mutActorHandlerContext,     ) ->
String {         message.
0.clone************** ()     } }pub
async  (fn****************  run  () {     letmut  (actor) **************=(****************** new_actor  (EchoActor {}). await********************** unwrap
();      lethello_world
=hello, world ”) to_string
();     letresult
=(actor.
send  (EchoMessage
(hello_world. clone())).await

;          assert_eq!
(result,Ok  (hello_world)); }

	

			
	

			

		
	
		





Distributed Actors currently in development  ************************************************ (Read More) ******************************************