schedutron

from threading import Lock, Thread
lock = Lock()
g = 0

def add_one():
   global g # Just used for demonstration. It’s bad to use the ‘global’ statement in general.
   lock.acquire()
   g += 1
   lock.release()

schedutron

import random, time
from threading import BoundedSemaphore, Thread

max_items = 5
container = BoundedSemaphore(max_items) # consider this as a container with a capacity of 5 items.
                                        # Defaults to 1 if nothing is passed.

def producer(nloops):
   for i in range(nloops):
   time.sleep(random.randrange(2, 5))

schedutron

import threading

num = 0
lock = Threading.Lock()

lock.acquire()
num += 1
lock.acquire() # This will block.
num += 2
lock.release()

schedutron

import random, time
from threading import Event, Thread

event = Event()

def waiter(event, nloops):
    for i in range(nloops):
    print(“%s. Waiting for the flag to be set.” % (i+1))
    event.wait() # Blocks until the flag becomes true.
    print(“Wait complete at:”, time.ctime())

schedutron

import random, time
from threading import Condition, Thread

# This will be used to represent the availability of a produced item.
condition = Condition()
box = []

def producer(box, nitems):
    for i in range(nitems):
    time.sleep(random.randrange(2, 5)) # Sleeps for some time.

schedutron

from random import randrange
from threading import Barrier, Thread
from time import ctime, sleep

num = 4
b = Barrier(num) # 4 threads will need to pass this barrier to get released.
names = [“Harsh”, “Lokesh”, “George”, “Iqbal”]

def player():
    name = names.pop()

schedutron

#!/usr/bin/env python3
"""Server for multithreaded (asynchronous) chat application."""
from socket import AF_INET, socket, SOCK_STREAM
from threading import Thread


def accept_incoming_connections():
    """Sets up handling for incoming clients."""
    while True:
        client, client_address = SERVER.accept()

schedutron

#!/usr/bin/env python3
"""Script for Tkinter GUI chat client."""
from socket import AF_INET, socket, SOCK_STREAM
from threading import Thread
import tkinter


def receive():
    """Handles receiving of messages."""
    while True:

schedutron

Saurabh Chaturvedi | FOSSASIA

Overview:

Throughout the course of this summer, I worked on FOSSASIA's Open Event project for GSoC.

Open Event Server

Majority of my work was done on the server side, i.e, on Open Event Server. The Open Event API Server enables organizers to manage events ranging from concerts to conferences, meet-ups, lecture series and much more. It offers features for events with several tracks and venues. Features also include subtle options like access and discount codes, session tracks, microlocations and so on.

schedutron

Generate Mazes with Disjoint Sets!

This script generates mazes that satisfy the following properties:

• There are no cycles in the maze
• Maze is always solvable
• Every cell is reachable from every other cell

The script also animates the maze-building process on the command-line (this was actually trickier than the maze generating algorithm itself)!

Usage