Jan 19, 2018 · Jan 5, 2018 · Jan 9, 2018 · Jan 9, 2018
diff --git a/examples/misc/multiprocess_sgskip.py b/examples/misc/multiprocess_sgskip.py
 # Uncomment the following lines to use the qt5 backend instead.
 #
 # import matplotlib
 # matplotlib.use('qt5Agg')
 # matplotlib.use('qt5agg')
 #
 # Alternatively, with Python 3.4+ you may add the line
 #
 # import multiprocessing as mp; mp.set_start_method("forkserver")
 #
 # immediately after the ``if __name__ == "__main__"`` check.

 import matplotlib.pyplot as plt

    def terminate(self):
        plt.close('all')

    def poll_draw(self):

        def call_back():
            while self.pipe.poll():
                command = self.pipe.recv()
                if command is None:
                    self.terminate()
                    return False
                else:
                    self.x.append(command[0])
                    self.y.append(command[1])
                    self.ax.plot(self.x, self.y, 'ro')
            self.fig.canvas.draw()
            return True

        return call_back
    def call_back(self):
        while self.pipe.poll():
            command = self.pipe.recv()
            if command is None:
                self.terminate()
                return False
            else:
                self.x.append(command[0])
                self.y.append(command[1])
                self.ax.plot(self.x, self.y, 'ro')
        self.fig.canvas.draw()
        return True

    def __call__(self, pipe):
        print('starting plotter...')

        self.pipe = pipe
        self.fig, self.ax = plt.subplots()
        timer = self.fig.canvas.new_timer(interval=1000)
        timer.add_callback(self.poll_draw())
        timer.add_callback(self.call_back)
        timer.start()

        print('...done')
Original file line number	Diff line number	Diff line change
Expand Up		@@ -19,7 +19,13 @@
		# Uncomment the following lines to use the qt5 backend instead.
		#
		# import matplotlib
		# matplotlib.use('qt5Agg')
		# matplotlib.use('qt5agg')
		#
		# Alternatively, with Python 3.4+ you may add the line
		#
		# import multiprocessing as mp; mp.set_start_method("forkserver")
		#
		# immediately after the ``if __name__ == "__main__"`` check.

		import matplotlib.pyplot as plt

Expand All		@@ -43,30 +49,26 @@ def __init__(self):
		def terminate(self):
		plt.close('all')

		def poll_draw(self):
Copy link Member QuLogicJan 9, 2018 Choose a reason for hiding this comment The reason will be displayed to describe this comment to others.Learn more. Huh, what was the point of this? Some kind of closure effect? Copy link ContributorAuthor anntzerJan 9, 2018 Choose a reason for hiding this comment The reason will be displayed to describe this comment to others.Learn more. not sure, but AFAICT it works without it...

		def call_back():
		while self.pipe.poll():
		command = self.pipe.recv()
		if command is None:
		self.terminate()
		return False
		else:
		self.x.append(command[0])
		self.y.append(command[1])
		self.ax.plot(self.x, self.y, 'ro')
		self.fig.canvas.draw()
		return True

		return call_back
		def call_back(self):
		while self.pipe.poll():
		command = self.pipe.recv()
		if command is None:
		self.terminate()
		return False
		else:
		self.x.append(command[0])
		self.y.append(command[1])
		self.ax.plot(self.x, self.y, 'ro')
		self.fig.canvas.draw()
		return True

		def __call__(self, pipe):
		print('starting plotter...')

		self.pipe = pipe
		self.fig, self.ax = plt.subplots()
		timer = self.fig.canvas.new_timer(interval=1000)
		timer.add_callback(self.poll_draw())
		timer.add_callback(self.call_back)
		timer.start()

		print('...done')
Expand Down