| import akka.actor.ActorSystem | |
| import akka.pattern.Patterns.after | |
| import scala.concurrent.duration._ | |
| val as = ActorSystem() | |
| val x = after(2.seconds, as.scheduler, global, Future.successful(1)).flatMap { _ => | |
| Future { | |
| // long operation that _starts_ after the delayed future completes | |
| 1 |
| Future { | |
| Thread.sleep(1000) | |
| } |
| def networkRequestWithRetries()(implicit as: ActorSystem): Future[String] = { | |
| networkRequest().recoverWith { | |
| case NetworkException => | |
| println("retrying") | |
| after(2.seconds, as.scheduler, global, Future.successful(1)).flatMap { _ => | |
| networkRequestWithRetries() | |
| } | |
| case t: Throwable => throw t | |
| } |
| def networkRequestWithRetries(): Future[String] = { | |
| networkRequest().recoverWith { | |
| case NetworkException => | |
| println("retrying") | |
| networkRequestWithRetries() | |
| case t: Throwable => throw t | |
| } | |
| } |
| import scala.concurrent.Future | |
| import scala.concurrent.ExecutionContext.Implicits.global | |
| import scala.util.Random | |
| object NetworkException extends Throwable | |
| def networkRequest(): Future[String] = { | |
| // let's assume a high rate of failure to make our examples | |
| // more interesting | |
| if ((Random.nextFloat * 100) < 80) |
| #include <google/protobuf/arena.h> | |
| using namespace google::protobuf; | |
| void main() { | |
| Arena arena; | |
| auto msg = Arena::CreateMessage<MyProto>(&arena); | |
| setup_myproto(msg, 1); | |
| push_to_queue(msg); |
| #include <google/protobuf/arena.h> | |
| using namespace google::protobuf; | |
| void main() { | |
| Arena arena; | |
| auto msg = Arena::CreateMessage<MyProto>(&arena); | |
| setup_myproto(msg); | |
| push_to_queue(msg); | |
| } |
Another strong component of Go is the standard library. It is structured much like the Unix/Linux operating system. There are lots of small components that can be combined together for more complex tasks. There are also indespensible, modern primitives such as the ability to create a networking server.
Create a web-server that exposes a typical AppNexus "status" endpoint. The web-server will support
A big reason people love Go is the concurrency primitives. Let's try them out with a coding challenge.
Launch 2 go-routines that send messages to each other over a channel. One go-routine will send "Ping" and the other will send "Pong." Each go-routine can only respond after they've received a message from the other go-routine. The exception is that the go-routine sending "Ping" can send an initial message