api2.py

from flask.ext.restful import Resource
from flask import Response

from ctypes import CDLL
gotest = CDLL("gotest.so")

class api2(Resource):
    def get(self):
        return gotest.GetValWithConcurrency()

gotest.go

// gotest
package main

import (
	"fmt"
	"sync"
)

import "C"

//export GetValWithConcurrency
func GetValWithConcurrency() int {
	fmt.Println("Called GetValWithConcurrency")
	someResults := make(chan int)

	var producer sync.WaitGroup
	var consumer sync.WaitGroup

	var makeResults = func(result chan int) {
		defer producer.Done()

		result <- 1
	}

	for i := 0; i < 100; i++ {
		producer.Add(1)
		go makeResults(someResults)
	}

	consumer.Add(1)
	var total int

	go func() {
		defer consumer.Done()
		for result := range someResults {
			total += result
		}
	}()

	producer.Wait()
	close(someResults)
	consumer.Wait()
	return total
}

func main() {

}