Форум программистов, компьютерный форум, киберфорум
Python для начинающих
Войти
Регистрация
Восстановить пароль
 
Рейтинг 4.83/6: Рейтинг темы: голосов - 6, средняя оценка - 4.83
V7
1 / 1 / 1
Регистрация: 30.09.2013
Сообщений: 27
1

Как в разных потоках сделать последовательный вывод строк?

30.09.2013, 13:44. Просмотров 1062. Ответов 11
Метки нет (Все метки)

Ошибка Print, при многопоточии:

Ну всем привет, загвостка вот в чём. Есть 100 потоков, они делают какую-то работу и постят результат через Print.
Вот в чём собстно проблем:

Код:
Python
1
print color("HEY - Some text ... :DDD blabla - "+strftime("%X", gmtime()),fg=85)
Кликните здесь для просмотра всего текста
Код
HEY - Some text ... : DDD blabla - 09:03:38
HEY - Some text ... : DDD blabla - 09:03:38
HEY - Some text ... : DDD blabla - 09:03:38
HEY - Some text ... : DDD blabla - 09:03:38
HEY - Some text ... : DDD blabla - 09:03:38
HEY - Some text ... : DDD blabla - 09:03:38
HEY - Some text ... : DDD blabla - 09:03:38HEY - Some text ... : DDD blabla - 09:03:38
HEY - Some text ... : DDD blabla - 09:03:38

HEY - Some text ... : DDD blabla - 09:03:38
HEY - Some text ... : DDD blabla - 09:03:38
HEY - Some text ... : DDD blabla - 09:03:38


Или картинка:
Как в разных потоках сделать последовательный вывод строк?


Так вопрос: как это исправить, чтоб был ровный резулт, или вообще, почему так выходит ?
0
Programming
Эксперт
94731 / 64177 / 26122
Регистрация: 12.04.2006
Сообщений: 116,782
30.09.2013, 13:44
Ответы с готовыми решениями:

Как сделать две формы, выполняющиеся в разных потоках.
Если упростить пример, то есть допустим метод, который создаёт вторую форму, и во время своего...

Получить перемешанный вывод при работе в разных потоках
В общем то, дело такое: о потоках до сего дня не знал, да и сейчас ничего не понимаю. Пишу, значит,...

как использовать методы класса в разных потоках?
Пишу программу для обмена данными с usb hid устройством. Чтобы получать данные от устройства в...

Метод выполнить в 11 разных потоках, соответственно для разных входных массивов
Здравствуйте, начал потихоньку разбираться в многопоточном программирование и не могу до конца...

11
4844 / 3265 / 465
Регистрация: 10.12.2008
Сообщений: 10,569
30.09.2013, 15:31 2
Цитата Сообщение от V7 Посмотреть сообщение
Так вопрос: как это исправить, чтоб был ровный резулт, или вообще, почему так выходит ?
выложи полный код
0
V7
1 / 1 / 1
Регистрация: 30.09.2013
Сообщений: 27
30.09.2013, 15:54  [ТС] 3
Весь код? Шутка D ?
Вот тот же, переделанный с меньшим функционалом ...
Проблема та же ... : (
Спасибо, если поможешь ! ...

Python
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
import Queue
import threading
import time
import os
import sys
import string
import datetime
from time import gmtime, strftime
from colors import color
 
def restart_program():
    python = sys.executable
    os.execl(python, python, * sys.argv)
 
exitFlag = 0
 
print ("+-----------------------------------------------------------------------------------+")
print ("")
print color("Fake program for CyberForum.ru site. By V7 (c)",fg=12)
print ("Message printer :DD")
print ("")
message=raw_input( " Message: " )
conn=input( " Times: " )
threadss=input(" Threads: ")
print ("+-----------------------------------------------------------------------------------+")
def start():
 class myThread (threading.Thread):
    def __init__(self, threadID, name, q):
        threading.Thread.__init__(self)
        self.threadID = threadID
        self.name = name
        self.q = q
    def run(self):
       for i in range(1, conn+1):
        print1(self.name+" "+str(i),i)
#-------------------------------------------------------------------------+++
 queueLock = threading.Lock()
 workQueue = Queue.Queue(10)
 threads = []
 threadID = 1
#-------------------------------------------------------------------------+++
 for i in range(1, threadss+1):
    thread = myThread(threadID, i, workQueue)
    thread.start()
    threads.append(thread)
    threadID += 1
#-------------------------------------------------------------------------+++
 queueLock.acquire()
 queueLock.release()
#-------------------------------------------------------------------------+++
 while not workQueue.empty():
     pass
#-------------------------------------------------------------------------+++
 exitFlag = 1
#-------------------------------------------------------------------------+++
 for t in threads:
    t.join()
 print ("+-----------------------------------------------------------------------------------+")
#-------------------------------------------------------------------------+++##11,198
def Question():
    print color(" Started at "+strftime("%X")+", completed at "+strftime("%X"),fg=191)
    print("")
    answer = raw_input(" And what we gonna do? (m - Again; s - From beginning; n - exit): ")
    if answer.strip() in "m".split():
        print("")
        print ("+-----------------------------------------------------------------------------------+")
        start()
        Question()
    if answer.strip() in "s".split():
        restart_program()
#-------------------------------------------------------------------------+++
def print1(name,count2):
    try:
        print color(" Message - "+message+" ("+strftime("%X", gmtime())+")"+ " | Count: "+str(count2)+" of "+str(conn),fg=85) #49print color("HEY - Some text ... :DDD blabla - "+strftime("%X", gmtime()),fg=85)#
    except:
       print color(" Error",fg=11)
#-------------------------------------------------------------------------+++
start()
Question()
0
4844 / 3265 / 465
Регистрация: 10.12.2008
Сообщений: 10,569
30.09.2013, 16:20 4
Цитата Сообщение от V7 Посмотреть сообщение
Вот тот же, переделанный с меньшим функционалом ...
Цитата Сообщение от V7 Посмотреть сообщение
Python
9
from colors import color
не думаю, что он запустится, так как colors.py не входит в библиотеку

Цитата Сообщение от V7 Посмотреть сообщение
Python
17
print ("+--------
во втором питоне print - это оператор, а не функция, поэтому круглые скобки не используются

Цитата Сообщение от V7 Посмотреть сообщение
Python
26
27
def start():
 class myThread
отступы - везде по четыре пробела, чтобы не гадать, что к чему относится

зачем 37-ая строка и всё, что с ней связано ?
есть неблокирующая очередь в библиотеке

Цитата Сообщение от V7 Посмотреть сообщение
Python
64
    if answer.strip() in "m".split():
чего ? ты пытаешься букву разделить ?

не надо вперемешку всё писать, пиши функции сверху, а операторы снизу

Цитата Сообщение от V7 Посмотреть сообщение
Python
23
conn=input( " Times: " )
а если там не то будет введено, тоже будешь вычислять и сохранять ?
0
V7
1 / 1 / 1
Регистрация: 30.09.2013
Сообщений: 27
30.09.2013, 17:00  [ТС] 5
Да ... насчёт библиотеки ...
Всё работает установи её через pip ... я пишу в Линуксе ...

Добавлено через 2 минуты
Я прекрасно знаю синтаксис Python-а, это мой не первый изученный язык, но не пойму, почему иногда криво, а иногда чётко идёт print ...
Лучшеб помог бы, чем всякую чушь нести, про пробелы ...

Допустим, я тоже не понимаю, почему ты зашифровал Pacific Ocean во вкладке Адрес ...
0
4844 / 3265 / 465
Регистрация: 10.12.2008
Сообщений: 10,569
30.09.2013, 23:25 6
Цитата Сообщение от V7 Посмотреть сообщение
Да ... насчёт библиотеки ...
Всё работает установи её через pip ... я пишу в Линуксе ...
https://pypi.python.org/pypi?%3Aaction=search&term=col ors&submit=search
там их десятки разных

Цитата Сообщение от V7 Посмотреть сообщение
почему иногда криво, а иногда чётко идёт print
я думаю, что ты неправильно сделал блокировки
а так как твой код нечитаем, потому что ты не знаешь про pep8, то я тебе и предложил его исправить сначала (привести в читаемое состояние), потому что пока что это просто мешанина какая-то

Цитата Сообщение от V7 Посмотреть сообщение
Лучшеб помог бы, чем всякую чушь нести, про пробелы ...
в питоне отступы имеют большое значение (семантику), поэтому их нужно писать чётко, чтобы нельзя было перепутать один блок с другим

Не по теме:

Цитата Сообщение от V7 Посмотреть сообщение
Допустим, я тоже не понимаю, почему ты зашифровал Pacific Ocean во вкладке Адрес ...
это не шифрование, а кодирование
если бы я это зашифровал, ты бы за всю жизнь не прочитал



Не по теме:

Цитата Сообщение от V7 Посмотреть сообщение
Я прекрасно знаю синтаксис Python-а, это мой не первый изученный язык
значит, ты ни одного языка не знаешь
для написания программ нужно ещё уметь составлять алгоритмы, язык в этом не поможет

2
V7
1 / 1 / 1
Регистрация: 30.09.2013
Сообщений: 27
02.10.2013, 14:25  [ТС] 7
Спасибо, помогли в другом форуме:

Ответ: Потоки между собой конфликтовали, тем самым некрасиво(не по очереди) постили сообщения.
Как исправить: создать отдельный поток, который постит сообщения:

Python
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
from threading import Thread
from Queue import Queue
from time import gmtime, strftime
 
def worker():
    while True:
        item = q.get()
        print item
        q.task_done()
 
q = Queue()
for i in range(1):
     t = Thread(target=worker)
     t.daemon = True
     t.start()
 
# ---- Somewhere in your threads
    q.put( color("HEY - Some text ... :DDD blabla - "+strftime("%X", gmtime()),fg=85) )
# -----
q.join()
Не по теме:

Не по теме:

На этом форуме, мне не помогли, оскорбили и снизили репутацию ...



Тема закрыта ...
0
V7
1 / 1 / 1
Регистрация: 30.09.2013
Сообщений: 27
05.10.2013, 00:12  [ТС] 8
Цитата Сообщение от accept Посмотреть сообщение
не думаю, что он запустится, так как colors.py не входит в библиотеку
Кстати через pip - установка той библиотеки, что использую я
Bash
1
sudo pip install ansicolors
0
4844 / 3265 / 465
Регистрация: 10.12.2008
Сообщений: 10,569
05.10.2013, 01:31 9
http://www.pip-installer.org/en/latest/usage.html#pip-install
Код
Install packages from:

    PyPI (and other indexes) using requirement specifiers.
    VCS project urls.
    Local project directories.
    Local or remote source archives.
https://pypi.python.org/pypi/ansicolors/1.0.2

обычно сразу с основного сайта ставлю в тот питон, который нужно (у меня их несколько)
0
V7
06.10.2013, 20:27  [ТС]
  #10

Не по теме:

Молодец : )

0
V7
1 / 1 / 1
Регистрация: 30.09.2013
Сообщений: 27
02.11.2014, 14:55  [ТС] 11
Сори accept, выскочило ...
0
Заблокирован
03.11.2014, 10:18 12
Не подскажете, где ясно и доступно описано использование многопоточности в Python?
0
IT_Exp
Эксперт
87844 / 49110 / 22898
Регистрация: 17.06.2006
Сообщений: 92,604
03.11.2014, 10:18

Заказываю контрольные, курсовые, дипломные и любые другие студенческие работы здесь.

Циклы обработки сообщений разных форм в разных потоках
Здравствуйте! Подскажите как реализовать циклы обработки сообщений разных форм в разных потоках. У...

Как запустить метод класса одновременно в разных потоках?
Как запустить метод класса одновременно в разных потоках? Будет ли конфликт между ними, или создать...

Изменение разных элементов вектора в разных потоках даёт отличный от join() результат, нежели при detach()
Имеется using V = vector<double>; using M = vector<V>; Есть функция матричного умножения A*B....

Как сделать вывод разных данных в зависимости от значения переменной
Здравствуйте. Вообщем у меня есть рабочий скрипт, который получает ответ от сервера и выводит...


Искать еще темы с ответами

Или воспользуйтесь поиском по форуму:
12
Ответ Создать тему
Опции темы

КиберФорум - форум программистов, компьютерный форум, программирование
Powered by vBulletin® Version 3.8.9
Copyright ©2000 - 2020, vBulletin Solutions, Inc.