thread.allocate_lock

src/core/ast.cpp

@@ -28,8 +28,8 @@ namespace pyston {
 int AST::next_lineno = 100000;
 
 AST::AST(AST_TYPE::AST_TYPE type) : type(type), lineno(++next_lineno) {
-    //if (lineno == 100644)
-        //raise(SIGTRAP);
+    // if (lineno == 100644)
+    // raise(SIGTRAP);
 }
 
 #endif

src/runtime/builtin_modules/thread.cpp

@@ -45,9 +45,27 @@ Box* startNewThread(Box* target, Box* args) {
     return boxInt(thread_id ^ 0x12345678901L);
 }
 
+static BoxedClass* thread_lock_cls;
+class BoxedThreadLock : public Box {
+public:
+    BoxedThreadLock() {}
+
+    DEFAULT_CLASS(thread_lock_cls);
+};
+
+Box* allocateLock() {
+    return new BoxedThreadLock();
+}
+
 void setupThread() {
     thread_module = createModule("thread", "__builtin__");
 
     thread_module->giveAttr("start_new_thread", new BoxedFunction(boxRTFunction((void*)startNewThread, BOXED_INT, 2)));
+    thread_module->giveAttr("allocate_lock", new BoxedFunction(boxRTFunction((void*)allocateLock, UNKNOWN, 0)));
+
+    thread_lock_cls = new BoxedHeapClass(object_cls, NULL, 0, sizeof(BoxedThreadLock), false);
+    thread_lock_cls->giveAttr("__name__", boxStrConstant("lock"));
+    thread_lock_cls->giveAttr("__module__", boxStrConstant("thread"));
+    thread_lock_cls->freeze();
 }
 }

test/tests/thread_test.py

-from thread import start_new_thread
+from thread import start_new_thread, allocate_lock
 import time
 
+print type(allocate_lock())
+
 done = 0
 def run(arg):
     global done