Did I find the right examples for you? yes no

All Samples(26)  |  Call(0)  |  Derive(0)  |  Import(26)
Execute computations asynchronously using threads or processes.

src/n/e/neurokernel-HEAD/examples/intro/visualize_output.py   neurokernel(Download)
"""
 
import futures
 
import numpy as np

src/n/e/neurokernel-HEAD/examples/intro/intro_demo.py   neurokernel(Download)
 
import argparse
import futures
import itertools
 

src/t/w/tweetf0rm-HEAD/tweetf0rm/handler/file_handler.py   tweetf0rm(Download)
 
from .base_handler import BaseHandler
import futures, os
from tweetf0rm.utils import full_stack
 

src/t/w/tweetf0rm-HEAD/tweetf0rm/handler/crawl_user_relationship_command_handler.py   tweetf0rm(Download)
from .base_handler import BaseHandler
import multiprocessing as mp
import futures, json, copy, time
from tweetf0rm.redis_helper import NodeQueue, NodeCoordinator
from tweetf0rm.utils import full_stack, get_keys_by_min_value, hash_cmd

src/c/h/CheesePrism-0.4.0b5/cheeseprism/wsgiapp.py   CheesePrism(Download)
from pyramid.session import UnencryptedCookieSessionFactoryConfig
from pyramid.settings import asbool
import futures
import logging
 

src/t/w/tweetf0rm-HEAD/tweetf0rm/proxies.py   tweetf0rm(Download)
 
from tweetf0rm.utils import full_stack
import requests, futures
 
def check_proxy(proxy, timeout):

src/t/w/tweetf0rm-HEAD/tweetf0rm/bootstrap.py   tweetf0rm(Download)
from tweetf0rm.proxies import proxy_checker
from tweetf0rm.scheduler import Scheduler
import time, os, tarfile, futures
 
def check_config(config):

src/h/a/hatch-0.9/hatch/observer.py   hatch(Download)
 
try:
    import futures
except ImportError:
    FUTURES = False

src/h/a/hatch-0.9/hatch/interface.py   hatch(Download)
import warnings
try:
    import futures
except ImportError:
    FUTURES = False

src/d/j/django-passaporte-web-1.1.4/identity_client/decorators.py   django-passaporte-web(Download)
#-*- coding: utf-8 -*-
import logging
from functools import wraps
 
import futures

  1 | 2 | 3  Next