FilesExpand file tree

 master

/

stdin.py

Copy path

Blame

More file actions

Blame

More file actions

Latest commit

 

History

History

History

29 lines (24 loc) · 690 Bytes

 master

/

stdin.py

Copy path

Top

File metadata and controls

• Code
• Blame

29 lines (24 loc) · 690 Bytes

Raw

Copy raw file

Download raw file

Open symbols panel

Edit and raw actions

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

#!/usr/bin/env python

from threading import Thread, Event, Lock

class input_buffer(object):

"""The shared input buffer between the main thread and the stdin thread"""

def __init__(self):

self.lock = Lock()

self.buf = ''

def add(self, data):

"""Add data to the buffer"""

self.lock.acquire()

try:

self.buf += data

finally:

self.lock.release()

def get(self):

"""Get the content of the buffer"""

self.lock.acquire()

try:

data = self.buf

if data:

self.buf = ''

return data

finally:

self.lock.release()