deadlines.go

package main

import (
	"fmt"
	"net"
	"strconv"
	"time"
)

func main() {
	addr, _ := net.ResolveTCPAddr("tcp", "localhost:1337")
	ln, _ := net.ListenTCP("tcp", addr)

	go func() {
		c, _ := ln.Accept()
		c.SetReadDeadline(time.Now().Add(1 * time.Second))
    
		go func() {
			time.Sleep(10 * time.Second)
			c.SetReadDeadline(time.Now().Add(1 * time.Second))
		}()
    
		for {
			b := make([]byte, 1000)
			n, err := c.Read(b)
			if err != nil {
        // try again after a short timeout
				time.Sleep(time.Second)
				continue
			}
			b = b[:n]
			fmt.Printf(string(b))
		}
	}()

	laddr, _ := net.ResolveTCPAddr("tcp", "localhost:1338")
	c, err := net.DialTCP("tcp", laddr, addr)
	if err != nil {
		panic(err)
	}

  // send a counter value every 100ms
	var counter int
	for {
		_, err := c.Write([]byte(strconv.Itoa(counter) + "\n"))
		if err != nil {
			panic(err)
		}
		counter++
		time.Sleep(100 * time.Millisecond)
	}

	select {}
}