This issue tracker has been migrated to GitHub, and is currently read-only.
For more information, see the GitHub FAQs in the Python's Developer Guide.

Author DemGiran
Recipients DemGiran
Date 2018-07-20.12:55:27
SpamBayes Score -1.0
Marked as misclassified Yes
Message-id <>
It seems that even without the as_completed call it has the same problem. 

# -*- coding: utf-8 -*-
import dns.resolver
import concurrent.futures
from pprint import pprint
from json import json

bucket = json.load(open('30_million_strings.json','r'))

def _dns_query(target, **kwargs):
    global bucket
    resolv = dns.resolver.Resolver()
    resolv.timeout = kwargs['function']['dns_request_timeout']
        resolv.query(target + '.com', kwargs['function']['query_type'])
        with open('out.txt', 'a') as f:
            f.write(target + '\n')
    except Exception:

def run(**kwargs):
    global bucket
    temp_locals = locals()
    pprint({k: v for k, v in temp_locals.items()})

    with concurrent.futures.ThreadPoolExecutor(max_workers=kwargs['concurrency']['threads']) as executor:
        for element in bucket:
            executor.submit(kwargs['function']['name'], element, **kwargs)

run(function={'name': _dns_query, 'dns_request_timeout': 1, 'query_type': 'MX'},
    concurrency={'threads': 15})
Date User Action Args
2018-07-20 12:55:27DemGiransetrecipients: + DemGiran
2018-07-20 12:55:27DemGiransetmessageid: <>
2018-07-20 12:55:27DemGiranlinkissue34168 messages
2018-07-20 12:55:27DemGirancreate