pprocess

Changelog

(0) -10 +10 +100 tip
18:4af6ce77fa14
2005-09-28 paulb changeset files shortlog graph [project @ 2005-09-28 16:15:49 by paulb] Added token stripping to produce mostly genuine words. Added a trace statement in the created process to signal the end of processing.
tests/Dict.py tests/start_indexer.py
17:3a227f484f48
2005-09-28 paulb changeset files shortlog graph [project @ 2005-09-28 16:15:15 by paulb] Changed the polling to apparently avoid reading from closed sockets.
parallel.py
16:5cd8b607d00e
2005-09-28 paulb changeset files shortlog graph [project @ 2005-09-28 16:00:06 by paulb] Reduced the sockets opened for a channel to a single pair. Removed the redundant signal handling code.
parallel.py
15:c34dad3cdba9
2005-09-28 paulb changeset files shortlog graph [project @ 2005-09-28 15:56:36 by paulb] Changed pipes to socket pairs.
parallel.py
14:2062a7f628ed
2005-09-28 paulb changeset files shortlog graph [project @ 2005-09-28 15:44:53 by paulb] Changed comment.
parallel.py
13:7ca994eb4dc9
2005-09-27 paulb changeset files shortlog graph [project @ 2005-09-27 18:23:46 by paulb] Added waiting for created processes.
tests/start_indexer.py
12:bcf32e883b5e
2005-09-27 paulb changeset files shortlog graph [project @ 2005-09-27 18:05:09 by paulb] Added channel closure after every window has been processed. Changed the Indexer and Searcher to record where words were found.
tests/Dict.py tests/start_indexer.py
11:73be19436b6c
2005-09-27 paulb changeset files shortlog graph [project @ 2005-09-27 18:04:03 by paulb] Fixed pipe creation, closing the other ends of pipes in each process. Made the Channel class's wait method blocking by default. Added some documentation about polling. Switched to sys.exit from SystemExit - this might avoid unnecessary exception handling in created processes.
parallel.py
10:cadfcdf9a910
2005-09-27 paulb changeset files shortlog graph [project @ 2005-09-27 17:28:25 by paulb] Changed the organisation of the Dict classes so that a Parser object sends word information back to the creating process via a channel, an Indexer object collects word information and builds an index, and a Searcher object provides a front-end to the index.
tests/Dict.py tests/start_indexer.py
9:0432c66b661e
2005-09-27 paulb changeset files shortlog graph [project @ 2005-09-27 17:26:44 by paulb] Changed the Exchange ready method to use poll rather than select. This should now detect pipe closures and automatically remove channels. Made a separate wait method for the Channel class. Changed the start function to explicitly close the open channel.
parallel.py
(0) -10 +10 +100 tip