More renumbering
This commit is contained in:
Crista Lopes
@@ -1,13 +0,0 @@
|
||||
Style #32
|
||||
==============================
|
||||
|
||||
Constraints:
|
||||
|
||||
- Variables are updated automatically based on changing values of
|
||||
other variables. Variable values possibly depend on data streams
|
||||
(keyboard, mouse, etc.)
|
||||
|
||||
Possible names:
|
||||
|
||||
- Reactive
|
||||
- Data-to-data
|
||||
@@ -1,113 +0,0 @@
|
||||
#!/usr/bin/env python
|
||||
|
||||
import sys, operator, string, os, threading
|
||||
from util import getch, cls, get_input
|
||||
from time import sleep
|
||||
|
||||
lock = threading.Lock()
|
||||
|
||||
#
|
||||
# The reactive infrastructure
|
||||
#
|
||||
class FreqObserver(threading.Thread):
|
||||
def __init__(self, freqs):
|
||||
threading.Thread.__init__(self)
|
||||
self.daemon = True
|
||||
self._end = False
|
||||
# freqs is the data to be observed and reacted to
|
||||
self._freqs = freqs
|
||||
self._freqs_0 = sorted(self._freqs.iteritems(), key=operator.itemgetter(1), reverse=True)
|
||||
self.start()
|
||||
|
||||
def run(self):
|
||||
while not self._end:
|
||||
lock.acquire()
|
||||
freqs_1 = sorted(self._freqs.iteritems(), key=operator.itemgetter(1), reverse=True)
|
||||
lock.release()
|
||||
if (freqs_1[0:25] != self._freqs_0[0:25]):
|
||||
self._update_display(freqs_1[0:25])
|
||||
self._freqs_0 = freqs_1
|
||||
sleep(0.01)
|
||||
|
||||
def stop(self):
|
||||
self._end = True
|
||||
|
||||
def _update_display(self, tuples):
|
||||
def refresh_screen(data):
|
||||
# clear screen
|
||||
cls()
|
||||
print data
|
||||
sys.stdout.flush()
|
||||
|
||||
data_str = ""
|
||||
for tf in tuples:
|
||||
data_str += str(tf[0]) + ' - ' + str(tf[1]) + '\n'
|
||||
refresh_screen(data_str)
|
||||
|
||||
#
|
||||
# The active part, dataflow-like
|
||||
#
|
||||
def characters():
|
||||
c = f.read(1)
|
||||
if c != "":
|
||||
yield c
|
||||
else:
|
||||
raise StopIteration()
|
||||
|
||||
def all_words():
|
||||
found_word = False
|
||||
start_char = True
|
||||
while not found_word:
|
||||
try:
|
||||
c = characters().next()
|
||||
except StopIteration:
|
||||
raise StopIteration()
|
||||
|
||||
if start_char == True:
|
||||
word = ""
|
||||
if c.isalnum():
|
||||
# We found the start of a word
|
||||
word = c.lower()
|
||||
start_char = False
|
||||
else:
|
||||
if c.isalnum():
|
||||
word += c.lower()
|
||||
else:
|
||||
# We found the end of a word, emit it
|
||||
start_char = True
|
||||
found_word = True
|
||||
yield word
|
||||
|
||||
def non_stop_words():
|
||||
stopwords = set(open('../stop_words.txt').read().split(',') + list(string.ascii_lowercase))
|
||||
while True:
|
||||
w = all_words().next()
|
||||
if not w in stopwords:
|
||||
yield w
|
||||
|
||||
def count_and_sort():
|
||||
freqs = {}
|
||||
# The declaration for reactive observation of freqs
|
||||
observer = FreqObserver(freqs)
|
||||
# Let's get input from the user, or let her
|
||||
# feed the input automatically
|
||||
while get_input():
|
||||
try:
|
||||
w = non_stop_words().next()
|
||||
lock.acquire()
|
||||
freqs[w] = 1 if w not in freqs else freqs[w]+1
|
||||
lock.release()
|
||||
except StopIteration:
|
||||
# Let's wait for the observer thread to die gracefully
|
||||
observer.stop()
|
||||
sleep(1)
|
||||
break
|
||||
|
||||
#
|
||||
# The main function
|
||||
#
|
||||
print "Press space bar to fetch words from the file one by one"
|
||||
print "Press ESC to switch to automatic mode"
|
||||
with open(sys.argv[1])as f:
|
||||
count_and_sort()
|
||||
|
||||
@@ -1,75 +0,0 @@
|
||||
import sys, os
|
||||
|
||||
#
|
||||
# getch in a platform-independent way
|
||||
# Credit: http://code.activestate.com/recipes/134892/
|
||||
#
|
||||
class _Getch:
|
||||
"""Gets a single character from standard input. Does not echo to the
|
||||
screen."""
|
||||
def __init__(self):
|
||||
try:
|
||||
self.impl = _GetchWindows()
|
||||
except ImportError:
|
||||
try:
|
||||
self.impl = _GetchMacCarbon()
|
||||
except(AttributeError, ImportError):
|
||||
self.impl = _GetchUnix()
|
||||
|
||||
def __call__(self): return self.impl()
|
||||
|
||||
|
||||
class _GetchUnix:
|
||||
def __init__(self):
|
||||
import tty, sys
|
||||
|
||||
def __call__(self):
|
||||
import sys, tty, termios
|
||||
fd = sys.stdin.fileno()
|
||||
old_settings = termios.tcgetattr(fd)
|
||||
try:
|
||||
tty.setraw(sys.stdin.fileno())
|
||||
ch = sys.stdin.read(1)
|
||||
finally:
|
||||
termios.tcsetattr(fd, termios.TCSADRAIN, old_settings)
|
||||
return ch
|
||||
|
||||
class _GetchWindows:
|
||||
def __init__(self):
|
||||
import msvcrt
|
||||
def __call__(self):
|
||||
import msvcrt
|
||||
return msvcrt.getch()
|
||||
|
||||
class _GetchMacCarbon:
|
||||
def __init__(self):
|
||||
import Carbon
|
||||
|
||||
def __call__(self):
|
||||
import Carbon
|
||||
if Carbon.Evt.EventAvail(0x0008)[0]==0: # 0x0008 is the keyDownMask
|
||||
return ''
|
||||
else:
|
||||
(what,msg,when,where,mod)=Carbon.Evt.GetNextEvent(0x0008)[1]
|
||||
return chr(msg & 0x000000FF)
|
||||
|
||||
getch = _Getch()
|
||||
|
||||
def cls():
|
||||
os.system(['clear','cls'][os.name == 'nt'])
|
||||
|
||||
|
||||
interactive = True
|
||||
def get_input():
|
||||
global interactive
|
||||
if not interactive:
|
||||
return True
|
||||
|
||||
while True:
|
||||
key = ord(getch())
|
||||
if key == 32: # space bar
|
||||
return True
|
||||
elif key == 27: # ESC
|
||||
interactive = False
|
||||
return True
|
||||
|
||||
Reference in New Issue
Block a user