SkTaskGroup Class Reference

#include <SkTaskGroup.h>

Inheritance diagram for SkTaskGroup:

Classes
struct	Enabler

Public Member Functions
	SkTaskGroup (SkExecutor &executor=SkExecutor::GetDefault())
	~SkTaskGroup ()
void	add (std::function< void(void)> fn)
void	batch (int N, std::function< void(int)> fn)
bool	done () const
void	wait ()

Detailed Description

Definition at line 20 of file SkTaskGroup.h.

Constructor & Destructor Documentation

SkTaskGroup()

SkTaskGroup::SkTaskGroup ( SkExecutor &  executor = SkExecutor::GetDefault() )

explicit

Definition at line 14 of file SkTaskGroup.cpp.

: fPending(0), fExecutor(executor) {}

~SkTaskGroup()

SkTaskGroup::~SkTaskGroup ( )

inline

Definition at line 24 of file SkTaskGroup.h.

{ this->wait(); }

Member Function Documentation

add()

void SkTaskGroup::add

(

std::function< void(void)>

fn

)

Definition at line 16 of file SkTaskGroup.cpp.

                                                {
    fPending.fetch_add(+1, std::memory_order_relaxed);
    fExecutor.add([this, fn{std::move(fn)}] {
        fn();
        fPending.fetch_add(-1, std::memory_order_release);
    });
}

batch()

void SkTaskGroup::batch	(	int	N,
		std::function< void(int)>	fn
	)

Definition at line 24 of file SkTaskGroup.cpp.

                                                        {
    // TODO: I really thought we had some sort of more clever chunking logic.
    fPending.fetch_add(+N, std::memory_order_relaxed);
    for (int i = 0; i < N; i++) {
        fExecutor.add([fn, i, this] {
            fn(i);
            fPending.fetch_add(-1, std::memory_order_release);
        });
    }
}

done()

bool SkTaskGroup::done

(

)

const

Definition at line 35 of file SkTaskGroup.cpp.

                             {
    return fPending.load(std::memory_order_acquire) == 0;
}

wait()

void SkTaskGroup::wait

(

)

Definition at line 39 of file SkTaskGroup.cpp.

                       {
    // Actively help the executor do work until our task group is done.
    // This lets SkTaskGroups nest arbitrarily deep on a single SkExecutor:
    // no thread ever blocks waiting for others to do its work.
    // (We may end up doing work that's not part of our task group.  That's fine.)
    while (!this->done()) {
        fExecutor.borrow();
    }
}

---

The documentation for this class was generated from the following files:

• third_party/skia/src/core/SkTaskGroup.h
• third_party/skia/src/core/SkTaskGroup.cpp