Ведение блога в ИТ

[Интеррапт]

Ну раз пошла такая пьянка, то и мы парикмахера напишем:

Code: Select all

class Barber:
    event = threading.Event()

    def cut_hair(self, customer):
        print "CUSTOMER {}: haircut (begin)".format(customer.id)
        self.event.clear()
        time.sleep(AVG_HAIRCUT_TIME)
        print "CUSTOMER {}: haircut (end)".format(customer.id)

    def sleep(self):
        self.event.wait()

    def wake_up(self):
        self.event.set()
        
        
class Customer:
    id = None

    def __init__(self, id):
        self.id = id


class BarberShop:
    barber = None
    pending_customers = []

    def __init__(self):
        BarberShop.lock = threading.Lock()
        self.barber = Barber()
        th = threading.Thread(target=self.do_work)
        th.start()

    def do_work(self):
        while True:
            BarberShop.lock.acquire()
            if len(self.pending_customers) > 0:
                customer = self.pending_customers.pop(0)
                BarberShop.lock.release()
                self.barber.cut_hair(customer)
            else:
                BarberShop.lock.release()
                print "BARBER: No customers, time to nap..."
                self.barber.sleep()
                print 'BARBER: New customer has arrived, wake up!'

    def enter(self, customer):
        BarberShop.lock.acquire()
        print "CUSTOMER {}: entered a shop".format(customer.id)

        if len(self.pending_customers) == NUMBER_OF_SEATS:
            BarberShop.lock.release()
            print "CUSTOMER {}: Wow, barber shop is full, I'm out of here!".format(customer.id)
        else:
            print "CUSTOMER {}: No worries, I'll wait".format(customer.id)
            self.pending_customers.append(customer)
            BarberShop.lock.release()
            self.barber.wake_up()

[crypto5]

А вот если окажется что барберов 10, то мне нужно будет одну цифру поменять, а ты будешь плодить баги и дедлоки

[Интеррапт]

А вот если окажется что барберов 10, то мне нужно будет одну цифру поменять, а ты будешь плодить баги и дедлоки

Просто тебе стыдно стало, что ты кучу потоков развел на ровном месте.

[crypto5]

А вот если окажется что барберов 10, то мне нужно будет одну цифру поменять, а ты будешь плодить баги и дедлоки

Просто тебе стыдно стало, что ты кучу потоков развел на ровном месте. Джавис, что тут скажешь.

Столько же сколько и ты развел

[Интеррапт]

А вот если окажется что барберов 10, то мне нужно будет одну цифру поменять, а ты будешь плодить баги и дедлоки

Просто тебе стыдно стало, что ты кучу потоков развел на ровном месте. Джавис, что тут скажешь.

Столько же сколько и ты развел

Да я даже не про этот конкретный случай, а про F/J Pool c I/O операциями

[crypto5]

А вот если окажется что барберов 10, то мне нужно будет одну цифру поменять, а ты будешь плодить баги и дедлоки

Просто тебе стыдно стало, что ты кучу потоков развел на ровном месте. Джавис, что тут скажешь.

Столько же сколько и ты развел

Да я даже не про этот конкретный случай, а про F/J Pool c I/O операциями

Ну твоего "малопоточного" кода я так и не увидел

[Интеррапт]

А я уже показал псевдокод и обьяснил концепцию. Обычный асинхронный read без выкрутасов.

[crypto5]

А я уже показал псевдокод и обьяснил концепцию. Обычный асинхронный read без выкрутасов.

Я думаю если ты начнешь его реализовывать то обнаружишь что выкрутасы там присутствуют.

[Интеррапт]

А я уже показал псевдокод и обьяснил концепцию. Обычный асинхронный read без выкрутасов.

Я думаю если ты начнешь его реализовывать то обнаружишь что выкрутасы там присутствуют.

Вряд-ли обнаружу. Все очень просто и логично.

[Zorkus]

Бенчмарки-то где?

[crypto5]

А я уже показал псевдокод и обьяснил концепцию. Обычный асинхронный read без выкрутасов.

Я думаю если ты начнешь его реализовывать то обнаружишь что выкрутасы там присутствуют.

Вряд-ли обнаружу. Все очень просто и логично.

Ненаписанный код всегда такой

[Berlaga]

Вряд-ли обнаружу. Все очень просто и логично.

Ненаписанный код всегда такой

В точку.

[Leo_G]

Так уж вышло, что получив неделю бана решил с пользой для себе провести время и начать вести ИТ блог.

Без особых заморочек пришлось взять поначалу наиболее прстую схему изложения в духе еду-вижу максимально напирая на знания и детали работающего кода. Из движков вроде как мне подошел WordPress.com с довольно простенькой и эффективной заяснялкой как оформлять код на станице

http://en.support.wordpress.com/code/po ... urce-code/

Если совсем коротко то за неделю удалось написать три статьи, что видимо эквивалентно десятку другому постов на привете

Собственно сам блог http://vyatkins.wordpress.com/ - если читать лень, то кликните накрутите пейджинг

Если кто ведет свой собственный блог в ИТ было бы неплохо обменятся опытом и послушать людей бывалых

Из очевидных преимуществ блога вижу пока две - можно показать свой уровень изложения + понимание специальной области, что как ни-крути должно характеризовать кандидата на позицию с лучшей стороны... ну, хотя бы положительно, что не ленив и жаден

И все... блог уже заброшен??
Вот взять бы всю парикмахерскую дискуссию отсюда и запостить в блог. Будет очень интересно. И делать особо ничего не надо, копи-паст.
Блог живой нужен.

[Мальчик-Одуванчик]

Ага а потом еще немножко усложнить задачку разрешив одному парикмахеру обслуживать нескольких посетителей

[AxelA]

Ну раз пошла такая пьянка, то и мы парикмахера напишем:

Гулять так гулять. Достаем из шир.. то есть тяжелую артилерию.
C++ с модными 11x свистелками и перделками.

Code: Select all

#include <stdio.h>

#include <atomic>
#include <condition_variable>
#include <deque>
#include <memory>
#include <mutex>
#include <queue>
#include <thread>
using namespace std;

class Barber;
class Client;
class Shop;
typedef shared_ptr<Client> ClientPtr;


static const int NUM_CHAIRS = 5;
static const int NUM_CLIENT_THREADS = 20;
static chrono::milliseconds BARBER_SESSION_TIME(50);
static chrono::milliseconds PAUSE_BETWEEN_CLIENTS(200);

class Client
{
public:
	const int _id;
	Client(int id) : _id(id) {};
};

class Shop
{
public:
	bool Serve(ClientPtr client)
	{
		lock_guard<mutex> guard(_lock);
		if (!_waitLine.empty() || _chair != nullptr)
		{
			if (_waitLine.size() >= NUM_CHAIRS)
			{
				printf("Client %d left unsatisfied.\n", client->_id);
				return false;
			}
			_waitLine.push(client);
			printf("Client %d is wating.\n", client->_id);
		}
		else
		{
			assert(_chair == nullptr);
			_chair = client;
			printf("Client %d is about to be served.\n", client->_id);
		}
		_signal.notify_one();
		return true;
	}
private:
	friend class Barber;

	ClientPtr GetNextClient()
	{
		while (true)
		{
			unique_lock<mutex> guard(_lock);
			if (_chair == nullptr && !_waitLine.empty())
			{
				_chair = _waitLine.front();
				_waitLine.pop();
			}
			if (_chair != nullptr)
			{
				return _chair;
			}
			printf("Barber is sleeping.\n");
			_signal.wait(guard);
			printf("Barber wakes up.\n");
		}
	}

	void DoneWithClient()
	{
		lock_guard<mutex> guard(_lock);
		assert(_chair != nullptr);
		_chair = nullptr;
		if (!_waitLine.empty())
		{
			_signal.notify_one();
		}
	}

	mutex _lock;
	condition_variable _signal;
	queue<ClientPtr> _waitLine;
	ClientPtr _chair;
};


class Barber
{
public:
	Barber(Shop& shop) : _shop(shop) {};
	void run()
	{
		while (true)
		{
			ClientPtr client = _shop.GetNextClient();
			CutEverything(client);
			_shop.DoneWithClient();
		}
	}
private:
	void CutEverything(ClientPtr client)
	{
		printf("Serving client#%d.\n", client->_id);
		this_thread::sleep_for(BARBER_SESSION_TIME);
	}

	Shop& _shop;
};

static void ClientThread(Shop* shop)
{
	static atomic_int clientID;

	while (true)
	{
		ClientPtr client = make_shared<Client>(clientID++);
		shop->Serve(client);
		this_thread::sleep_for(PAUSE_BETWEEN_CLIENTS);
	}
}

static void BarberThread(Shop* shop)
{
	Barber barber(*shop);
	barber.run();
}

static void test()
{
	Shop shop;
	thread barberThread(&BarberThread, &shop);

	thread clientThreads[NUM_CLIENT_THREADS];
	for (int i = 0; i < NUM_CLIENT_THREADS; i++)
	{
		clientThreads[i] = thread(ClientThread, &shop);
	}

	this_thread::sleep_for(chrono::hours(1000));
}

void main()
{
	test();
}