ChanUp Channels

A Wrapper on top of go channels which supports one complex use case. A ChanUp channel buffer has a length of One. ChanUp channel can be used to make producer and consumer of channel independent of each other. The execution flow of no process gets blocked.

Functionality

• ChanUp channel never blocks producer or consumer.
• A producer Puts a value if channel is empty
• A producer Updates channel with new value if it is holding a stale value.
• A consumer gets a value if available.

Installation

go get github.com/subbuv26/chanup

Usage

Example 1:

package main

import (
	"fmt"
	"github.com/subbuv26/chanup"
)

type testType struct {
	a int
	s string
}

func main() {
	ch := chanup.GetChan()
	status := ch.Put(testType{
		a: 10,
		s: "Sample",
	})
	if status == chanup.FAILED {
		// Log
	}
	
	testValue := testType{
		a: 20,
		s: "Sample2",
	}
	status = ch.Update(testValue)

	if status != chanup.UPDATE {
		// Log
	}

	val := ch.Get()
	if val == nil {
		// Log
	}
	tv := val.(testType)
	fmt.Println(tv)
}

Example 2:

package main

import (
	"fmt"
	"github.com/subbuv26/chanup"
	"time"
)

type testType struct {
	a int
	s string
}

func producer(chp *chanup.ChanUp) {
	tv := testType{
		100,
		"sample",
	}
	for {
		time.Sleep(time.Second)
		chp.Update(tv)
		tv.a += 1
	}
}

func consumer(chc *chanup.ChanUp) {
	for {
		if val := chc.Get(); val != nil {
			tv := val.(testType)
			fmt.Println(tv)
			time.Sleep(time.Second * 5)
		}
	}
}

func main() {
	ch := chanup.GetChan()

	go producer(ch)

	consumer(ch)
}