Skip to main content
Tweeted twitter.com/#!/StackOverflowPT/status/588807623228710913
Português
Fonte Link
Victor Stafusa
  • 64,9mil
  • 9
  • 120
  • 189

Bom, estou com uma certa dificuldade no uso de threads, preciso realizar o seguinte procedimento:

tenhoTenho vários itens para serem comparados com uma variavelvariável, poremporém essa comparação leva um certo tempo, então gostaria de fazer variasvárias comparações ao mesmo tempo e caso alguma comparação deresulte verdadeira, parar todas as outras e seguir pra outra parte do código.

tenteiTentei usar o join, mas acaba atrasando o programa, pois preciso aguardar comparações que se tornaram irrelevantes a partir do momento em que eu encontrei o que precisava, tentei tbm. Tentei também sem o join, poremporém a execução de outras threads, acabam atrapalhando o fluxo do meu programa.

algo +-Algo mais ou menos assim:

para cada 10 itens da lista 
use cada item em uma comparação distinta 
se alguma das 10 comparações retornar como True, feche todas as outras comparações e vá para outra função 
senão, pegue mais 10 itens da lista e refaça a comparação
Para cada 10 itens da lista 
Use cada item em uma comparação distinta 
Se alguma das 10 comparações retornar como True, feche todas as outras comparações e vá para outra função 
Senão, pegue mais 10 itens da lista e refaça a comparação

deDe forma mais genericagenérica fiz da seguinte forma:

palavras = ['palavra1', 'palavra2', 'palavra3', 'palavra4']
nth = 2
threads = []
def execute(palavra):
    print('\ntentando palavra'+palavra)
    time.sleep(5)
    print(palavra+'finalizada')
for nome in palavras:
    threads.append(nome)
    if len(threads)>= nth:
        for item in threads:
            _thread.start_new_thread(execute, (item,))
        threads = []
palavras = ['palavra1', 'palavra2', 'palavra3', 'palavra4']
nth = 2
threads = []
def execute(palavra):
    print('\ntentando palavra'+palavra)
    time.sleep(5)
    print(palavra+'finalizada')
for nome in palavras:
    threads.append(nome)
    if len(threads)>= nth:
        for item in threads:
            _thread.start_new_thread(execute, (item,))
        threads = []

entretantoEntretanto, ele inicia continuamente as threads, eu. Eu precisava manter somente 10, ou seja, ele pega 10 itens, compara, e na medida que terminar uma comparação, ele pega mais um item pra ficar sempre em 10 comparações.

Bom, estou com uma certa dificuldade no uso de threads, preciso realizar o seguinte procedimento

tenho vários itens para serem comparados com uma variavel, porem essa comparação leva um certo tempo, então gostaria de fazer varias comparações ao mesmo tempo e caso alguma comparação de verdadeira, parar todas as outras e seguir pra outra parte do código

tentei usar o join, mas acaba atrasando o programa, pois preciso aguardar comparações que se tornaram irrelevantes a partir do momento em que eu encontrei o que precisava, tentei tbm sem o join, porem a execução de outras threads, acabam atrapalhando o fluxo do meu programa

algo +-

para cada 10 itens da lista 
use cada item em uma comparação distinta 
se alguma das 10 comparações retornar como True, feche todas as outras comparações e vá para outra função 
senão, pegue mais 10 itens da lista e refaça a comparação

de forma mais generica fiz da seguinte forma:

palavras = ['palavra1', 'palavra2', 'palavra3', 'palavra4']
nth = 2
threads = []
def execute(palavra):
    print('\ntentando palavra'+palavra)
    time.sleep(5)
    print(palavra+'finalizada')
for nome in palavras:
    threads.append(nome)
    if len(threads)>= nth:
        for item in threads:
            _thread.start_new_thread(execute, (item,))
        threads = []

entretanto, ele inicia continuamente as threads, eu precisava manter somente 10, ou seja, ele pega 10 itens, compara, na medida que terminar uma comparação, ele pega mais um item pra ficar sempre em 10 comparações

Bom, estou com uma certa dificuldade no uso de threads, preciso realizar o seguinte procedimento:

Tenho vários itens para serem comparados com uma variável, porém essa comparação leva um certo tempo, então gostaria de fazer várias comparações ao mesmo tempo e caso alguma comparação resulte verdadeira, parar todas as outras e seguir pra outra parte do código.

Tentei usar o join, mas acaba atrasando o programa, pois preciso aguardar comparações que se tornaram irrelevantes a partir do momento em que eu encontrei o que precisava. Tentei também sem o join, porém a execução de outras threads acabam atrapalhando o fluxo do meu programa.

Algo mais ou menos assim:

Para cada 10 itens da lista 
Use cada item em uma comparação distinta 
Se alguma das 10 comparações retornar como True, feche todas as outras comparações e vá para outra função 
Senão, pegue mais 10 itens da lista e refaça a comparação

De forma mais genérica fiz da seguinte forma:

palavras = ['palavra1', 'palavra2', 'palavra3', 'palavra4']
nth = 2
threads = []
def execute(palavra):
    print('\ntentando palavra'+palavra)
    time.sleep(5)
    print(palavra+'finalizada')
for nome in palavras:
    threads.append(nome)
    if len(threads)>= nth:
        for item in threads:
            _thread.start_new_thread(execute, (item,))
        threads = []

Entretanto, ele inicia continuamente as threads. Eu precisava manter somente 10, ou seja, ele pega 10 itens, compara e na medida que terminar uma comparação, ele pega mais um item pra ficar sempre em 10 comparações.

Fonte Link
x-x
  • 91
  • 2

Threads em python 3.4

Bom, estou com uma certa dificuldade no uso de threads, preciso realizar o seguinte procedimento

tenho vários itens para serem comparados com uma variavel, porem essa comparação leva um certo tempo, então gostaria de fazer varias comparações ao mesmo tempo e caso alguma comparação de verdadeira, parar todas as outras e seguir pra outra parte do código

tentei usar o join, mas acaba atrasando o programa, pois preciso aguardar comparações que se tornaram irrelevantes a partir do momento em que eu encontrei o que precisava, tentei tbm sem o join, porem a execução de outras threads, acabam atrapalhando o fluxo do meu programa

algo +-

para cada 10 itens da lista 
use cada item em uma comparação distinta 
se alguma das 10 comparações retornar como True, feche todas as outras comparações e vá para outra função 
senão, pegue mais 10 itens da lista e refaça a comparação

de forma mais generica fiz da seguinte forma:

palavras = ['palavra1', 'palavra2', 'palavra3', 'palavra4']
nth = 2
threads = []
def execute(palavra):
    print('\ntentando palavra'+palavra)
    time.sleep(5)
    print(palavra+'finalizada')
for nome in palavras:
    threads.append(nome)
    if len(threads)>= nth:
        for item in threads:
            _thread.start_new_thread(execute, (item,))
        threads = []

entretanto, ele inicia continuamente as threads, eu precisava manter somente 10, ou seja, ele pega 10 itens, compara, na medida que terminar uma comparação, ele pega mais um item pra ficar sempre em 10 comparações