concurrent.futures

    1热度

    1回答

    使用CompletionStage返回结果

    我是新来玩框架和Java8。我正在尝试在Play中编写一个简单的Web服务，它符合Asynch模型，并允许Web服务调用快速返回，为异步线程留下沉重的负担。 我有一个非常基本的操作 public CompletionStage<Result> getPeople() { } 在调用真正的处理必须从数据库中加载的人的数据。 db方法是 List<People> people = dbServ
    lambda playframework-2.0 java.util.concurrent concurrent.futures completable-future 2016-04-22

    -1热度

    1回答

    我会得到性能提升结合使用Flask的concurrent.futures

    我想知道是否可以使用Flask的concurrent.futures。这是一个例子。 import requests from flask import Flask from concurrent.futures import ThreadPoolExecutor executor = ThreadPoolExecutor(max_workers=10) app = Flask(__na
    python multithreading flask concurrent.futures 2016-01-22

    3热度

    1回答

    Java进程

    这是用我未来的代码片断未来的任务完成后，没有放弃。 import java.util.concurrent.*; import java.util.*; public class FutureDemo{ public FutureDemo(){ /* Future */ ExecutorService service = Executors.newF
    java executorservice concurrent.futures 2015-10-26

    7热度

    1回答

    芹菜与ProcessPoolExecutor /的ThreadPoolExecutor

    我创建一个Django的web服务器，它允许用户在本地计算机上运行一些“可执行文件”，并通过网页来分析它们的输出。 我以前使用的芹菜任务队列，以便在类似情况下运行“可执行文件”。然而，Python的concurrent.futures读了之后，我开始怀疑我是否应该使用ThreadPoolExecutor，或ProcessPoolExecutor（或ThreadPoolExecutor一个Proce
    python django multiprocessing celery concurrent.futures 2016-05-18

    1热度

    1回答

    如何在concurrent.futures.ThreadPoolExecutor中使用不会导致死锁的锁？

    我正在处理Jira更新日志历史数据，并且由于大量的数据以及大多数处理时间都是基于I/O的事实，我认为异步方法可能运作良好。 我都issue_id的，这我送入一个功能，使通过jira-python API的请求的列表，提取信息为dict，然后通过在DictWriter一个通过写出来。为了使它成为线程安全的，我从threading模块导入了一个Lock()，我也通过了该模块。在测试中，它似乎在某个时间
    python multithreading concurrent.futures 2016-07-14

    -1热度

    1回答

    使用futures.concurrent带班

    我有一个主要的，看起来像下面这样： import gather_filings_per_filer import os from concurrent import futures def put_last_i(arg): with open(os.path.dirname(os.path.abspath(__file__)) + '/last_i.txt','w') as f:
    python concurrent.futures 2016-01-05

    0热度

    2回答

    CPU对FutureTask.awaitDone的影响

    我们广泛使用Java ThreadPoolExecutor。具体来说，我们遵循一个fork连接模式，构建一个可调用列表并在它们上使用invokeAll（）的定时变体。我们只使用这些线程池来执行I/O（非CPU密集型）操作，但是看着线程转储，我们看到这些特定线程消耗高CPU。查看FutureTask.awaitDone（）实现，我可以看到采用对LockSupport.parkNanos（）的交叉调用
    java performance concurrency concurrent.futures 2015-10-19

    0热度

    1回答

    蟒蛇并行计算任务蛮力

    /*这不适用于任何非法，只是我的学校只使用7个整数，我想看看我是否能够及时工作，因为目前我需要1.59年破解密码。学校拥有自己的私人服务器，可供任何有关人员使用，并且很容易检测到。 */ 我只是想用多处理或者concurrent.futures来让这个密码破解者在合理的时间内运行。 这是我在并联它 import smtplib from concurrent.futures import Thr
    python python-2.7 python-3.x python-multiprocessing concurrent.futures 2015-11-04

    0热度

    1回答

    For comprehension Dynamic List of Futures：Scala

    我试图用理解来执行系列期货清单。一个未来的输出成为未来未来的输入。以下是示例代码。 for { x <- plugins(0).execute(input) y <- plugins(1).execute(x) z <- plugins(2).excute(y) } yield z 上面的代码更像瀑布，每个插件（i）在某些输入上执行，并将输出传递给
    scala for-comprehension concurrent.futures 2015-12-31

    0热度

    1回答

    gevent + concurrent.futures和SQLAlchemy

    我正在运行并且pyramid应用程序在gentic异步工作者的gunicorn容器中， 其中一个端点是通过kombu汇集AMQP的长池端点。 如果长池withing 30秒超时返回前返回从AMQP的一些数据，我需要将其保存到Postgres的，现在的问题是： 是否确定在上下文中启动concurrent.futures.ThreadPoolExecutor上的应用程序在GEVENT循环中运行，并处理
    sqlalchemy future gunicorn gevent concurrent.futures 2016-06-09
最新问题