wilk

(async () => {
  const { job } = require('microjob')

  try {
    // this function will be executed in another thread
    const res = await job(() => {
      let i = 0
      for (i = 0; i < 1000000; i++) {
        // heavy CPU load ...
      }

wilk

func main() {
  go func(msg string) {
    fmt.Println(msg)
  }("going")
}

wilk

# async tests

from time import sleep
from concurrent.futures import ThreadPoolExecutor, wait

def hello_world(delay):
  print("hello world {delay}".format(delay=delay))
  sleep(delay)
  print("hello there {delay}".format(delay=delay))
  return "done {delay}".format(delay=delay)

wilk

import asyncio
from time import sleep
from concurrent.futures import ThreadPoolExecutor

async def hello_world(loop, delay):
  print("hello world")
  await loop.run_in_executor(ThreadPoolExecutor(), sleep, delay)
  print("hello there")
  return "done"

wilk

version: "3"

services:
  django-app:
    image: your_django_image:version
    build:
      context: ./app
    env_file: .env
    ports:
      - "8080:80"

wilk

package main

import (
  "fmt"
  "os"
  "errors"
  "strconv"
  "strings"
  "github.com/parnurzeal/gorequest"
  "gopkg.in/mgo.v2"

wilk

import (
  "errors"
  "strings"
  "github.com/parnurzeal/gorequest"
)

type Transaction struct {
  Date string
  Account string
  Description string

wilk

import (
  "fmt"
  "strconv"
  "sync"
)

type Transaction struct {
  Date string
  Account string
  Description string

wilk

goxfer:
  command: go run src/goxfer.go
  image: data.golang1.9:1
  environment:
    - DB_HOST=mongodb
    - DB_NAME=collector
    - DB_COLLECTION_NAME=collected
    - BUXFER_API_ENDPOINT=https://www.buxfer.com/api
    - BUXFER_USERNAME=your_buxfer_username
    - BUXFER_PASSWORD=your_buxfer_password

wilk

package main

import (
  "fmt"
  "strconv"
  "gopkg.in/mgo.v2"
)

type Transaction struct {
  Date string