| package main | |
| import ( | |
| "bytes" | |
| "encoding/json" | |
| "flag" | |
| "fmt" | |
| "io/ioutil" | |
| "log" | |
| "net/http" |
| package main | |
| import ( | |
| "bufio" | |
| "bytes" | |
| "fmt" | |
| "io" | |
| "log" | |
| "os" | |
| ) |
| package main | |
| import ( | |
| "fmt" | |
| "sync" | |
| ) | |
| func main() { | |
| wg := new(sync.WaitGroup) | |
| stop := make(chan bool) |
| package main | |
| import "fmt" | |
| func worker(row int, input chan int, output chan int, done chan int) { | |
| display := "" | |
| previous := 0 | |
| for i := 0; i < row+1; i++ { | |
| read := <-input | |
| display += fmt.Sprintf("%d ", read) |
| package mapreduce | |
| func MapReduce(mapper func(interface{}, chan interface{}), | |
| reducer func(chan interface{}, chan interface{}), | |
| input chan interface{}, | |
| pool_size int) interface{} | |
| { | |
| reduce_input := make(chan interface{}); | |
| reduce_output := make(chan interface{}); | |
| worker_output := make(chan chan interface{}, pool_size); |
| package main | |
| import ( | |
| "fmt" | |
| "net/http" | |
| ) | |
| func broadcaster(in chan chan string, out chan chan string, listen chan string) { | |
| chans := map[chan string]bool{} | |
| for { |
👯 👯 👯 👯 👯 👯 👯 👯 👯 👯 👯 👯 👯 👯 👯 👯 👯 👯 👯 👯 👯 👯 👯 👯
Hi backers!
First, for those of you still waiting for your pen(s), we're still on schedule. The schedule was posted a few updates ago (update #22). The 3 remaining batches are shipped from our manufacturer in China on :
| curl -s http://www.jma.go.jp/jp/quake/quake_local_index.html | grep Ｍ | sed "s/.*nowrap>Ｍ\(.*\)<\/td><td\ no.*/\1/" | | |
| sed 's/１/1/g; s/２/2/g; s/３/3/g; s/４/4/g; s/５/5/g; s/６/6/g; s/７/7/g; s/８/8/g; s/９/9/g; s/０/0/g; s/．/\./g' | | |
| spark |
| <!DOCTYPE html> | |
| <html> | |
| <head> | |
| <title>The d3 test</title> | |
| <style> | |
| .chart { | |
| shape-rendering: crispEdges; | |
| } | |
| .main text { |
| package main | |
| import ( | |
| "flag" | |
| "log" | |
| "net/http" | |
| "os" | |
| ) |
