Wskazówki: tworzenie sieci przetwarzania obrazów

Niniejszy dokument przedstawia sposób tworzenia sieci bloków asynchroniczny komunikat przetwarzania obrazu.

Sieci określa, jakie operacje do wykonania na obraz z jego właściwości.W tym przykładzie Przepływ model na trasie obrazy za pośrednictwem sieci.W modelu przepływ danych niezależnych składników programu komunikują się ze sobą przez wysłanie wiadomości.Gdy składnik odbiera wiadomość, można wykonać kilka akcji i następnie przekazać wynik tego działania do innego składnika.Porównaj to z Przepływ sterowania model, w którym aplikacja używa struktur sterujących, na przykład, instrukcje warunkowe, pętle i tak dalej, aby określić kolejność operacji w programie.

Tworzy sieć opartą na przepływ rurociąg zadań.Każdy etap potoku wykonuje jednocześnie częścią ogólnej zadania.Odpowiednio do tego zestawu dla jest wiersz motoryzacyjnym.Każdy pojazd przechodzi przez wiersz zestawu, jedna stacja montuje ramki, instaluje innego silnika i tak dalej.Przez włączenie wielu pojazdów, które mają być montowane jednocześnie, wiersz zestawu zawiera większa przepustowość niż montażu pojazdów kompletnych jednej naraz.

Wymagania wstępne

Przed rozpoczęciem tego instruktażu, przeczytaj następujące dokumenty:

• Bloki komunikatów asynchronicznych

• Porady: korzystanie z filtra bloku komunikatów

• Wskazówki: tworzenie agenta przepływu danych

Zaleca się także poznać podstawowe informacje o GDI+ przed rozpoczęciem tego instruktażu.Aby uzyskać więcej informacji o GDI+, zobacz GDI +.

Sekcje

Ten instruktaż zawiera następujące sekcje:

• Definiowanie funkcji przetwarzania obrazu

• Tworzenie sieci przetwarzania obrazu

• Kompletny przykład

Definiowanie funkcji przetwarzania obrazu

W tej sekcji przedstawiono funkcje pomocy technicznej, używane przez sieć przetwarzania obrazu do pracy z obrazami, które są odczytywane z dysku.

Następujące funkcje GetRGB i MakeColor, wyodrębnianie i łączenie poszczególnych składników danego koloru, odpowiednio.

// Retrieves the red, green, and blue components from the given 
// color value. 
void GetRGB(DWORD color, BYTE& r, BYTE& g, BYTE& b)
{
   r = static_cast<BYTE>((color & 0x00ff0000) >> 16);
   g = static_cast<BYTE>((color & 0x0000ff00) >> 8);
   b = static_cast<BYTE>((color & 0x000000ff));
}

// Creates a single color value from the provided red, green,  
// and blue components.
DWORD MakeColor(BYTE r, BYTE g, BYTE b)
{
   return (r<<16) | (g<<8) | (b);
}

Następująca funkcja ProcessImage, wywołań danego std::function obiektu transform wartość koloru każdego piksela GDI+Bitmap obiektu.ProcessImage Działać zastosowań concurrency::parallel_for algorytm przetworzyć każdy wiersz bitmapy równolegle.

// Calls the provided function for each pixel in a Bitmap object. 
void ProcessImage(Bitmap* bmp, const function<void (DWORD&)>& f)
{
   int width = bmp->GetWidth();
   int height = bmp->GetHeight();

   // Lock the bitmap.
   BitmapData bitmapData;
   Rect rect(0, 0, bmp->GetWidth(), bmp->GetHeight());
   bmp->LockBits(&rect, ImageLockModeWrite, PixelFormat32bppRGB, &bitmapData);

   // Get a pointer to the bitmap data.
   DWORD* image_bits = (DWORD*)bitmapData.Scan0;

   // Call the function for each pixel in the image.
   parallel_for (0, height, [&, width](int y)
   {      
      for (int x = 0; x < width; ++x)
      {
         // Get the current pixel value.
         DWORD* curr_pixel = image_bits + (y * width) + x;

         // Call the function.
         f(*curr_pixel);
      }
   });

   // Unlock the bitmap.
   bmp->UnlockBits(&bitmapData);
}

Następujące funkcje Grayscale, Sepiatone, ColorMask, i Darken, call ProcessImage funkcji, aby przekształcić wartość koloru każdego piksela w Bitmap obiektu.Każda z tych funkcji jest używane wyrażenie lambda zdefiniowanie transformacji kolorów o jeden piksel.

// Converts the given image to grayscale.
Bitmap* Grayscale(Bitmap* bmp) 
{
   ProcessImage(bmp, 
      [](DWORD& color) {
         BYTE r, g, b;
         GetRGB(color, r, g, b);

         // Set each color component to the average of  
         // the original components.
         BYTE c = (static_cast<WORD>(r) + g + b) / 3;
         color = MakeColor(c, c, c);
      }
   );
   return bmp;
}

// Applies sepia toning to the provided image.
Bitmap* Sepiatone(Bitmap* bmp) 
{
   ProcessImage(bmp, 
      [](DWORD& color) {
         BYTE r0, g0, b0;
         GetRGB(color, r0, g0, b0);

         WORD r1 = static_cast<WORD>((r0 * .393) + (g0 *.769) + (b0 * .189));
         WORD g1 = static_cast<WORD>((r0 * .349) + (g0 *.686) + (b0 * .168));
         WORD b1 = static_cast<WORD>((r0 * .272) + (g0 *.534) + (b0 * .131));

         color = MakeColor(min(0xff, r1), min(0xff, g1), min(0xff, b1));
      }
   );
   return bmp;
}

// Applies the given color mask to each pixel in the provided image.
Bitmap* ColorMask(Bitmap* bmp, DWORD mask)
{
   ProcessImage(bmp, 
      [mask](DWORD& color) {
         color = color & mask;
      }
   );
   return bmp;
}

// Darkens the provided image by the given amount.
Bitmap* Darken(Bitmap* bmp, unsigned int percent)
{
   if (percent > 100)
      throw invalid_argument("Darken: percent must less than 100.");

   double factor = percent / 100.0;

   ProcessImage(bmp, 
      [factor](DWORD& color) {
         BYTE r, g, b;
         GetRGB(color, r, g, b);
         r = static_cast<BYTE>(factor*r);
         g = static_cast<BYTE>(factor*g);
         b = static_cast<BYTE>(factor*b);
         color = MakeColor(r, g, b);
      }
   );
   return bmp;
}

Następująca funkcja GetColorDominance, wymaga również ProcessImage funkcji.Jednak zamiast zmieniać wartości poszczególnych kolorów, to funkcja używa concurrency::combinable obiekty do obliczenia, czy składnik koloru czerwonego, zielonego lub niebieskiego dominuje obrazu.

// Determines which color component (red, green, or blue) is most dominant 
// in the given image and returns a corresponding color mask.
DWORD GetColorDominance(Bitmap* bmp)
{
   // The ProcessImage function processes the image in parallel. 
   // The following combinable objects enable the callback function 
   // to increment the color counts without using a lock.
   combinable<unsigned int> reds;
   combinable<unsigned int> greens;
   combinable<unsigned int> blues;

   ProcessImage(bmp, 
      [&](DWORD& color) {
         BYTE r, g, b;
         GetRGB(color, r, g, b);
         if (r >= g && r >= b)
            reds.local()++;
         else if (g >= r && g >= b)
            greens.local()++;
         else
            blues.local()++;
      }
   );

   // Determine which color is dominant and return the corresponding 
   // color mask. 

   unsigned int r = reds.combine(plus<unsigned int>());
   unsigned int g = greens.combine(plus<unsigned int>());
   unsigned int b = blues.combine(plus<unsigned int>());

   if (r + r >= g + b)
      return 0x00ff0000;
   else if (g + g >= r + b)
      return 0x0000ff00;
   else 
      return 0x000000ff;
}

Następująca funkcja GetEncoderClsid, pobiera identyfikator klasy dla danego typu MIME kodera.Aplikacja używa tej funkcji do pobierania kodera dla mapy bitowej.

// Retrieves the class identifier for the given MIME type of an encoder. 
int GetEncoderClsid(const WCHAR* format, CLSID* pClsid)
{
   UINT  num = 0;          // number of image encoders
   UINT  size = 0;         // size of the image encoder array in bytes

   ImageCodecInfo* pImageCodecInfo = nullptr;

   GetImageEncodersSize(&num, &size);
   if(size == 0)
      return -1;  // Failure

   pImageCodecInfo = (ImageCodecInfo*)(malloc(size));
   if(pImageCodecInfo == nullptr)
      return -1;  // Failure

   GetImageEncoders(num, size, pImageCodecInfo);

   for(UINT j = 0; j < num; ++j)
   {
      if( wcscmp(pImageCodecInfo[j].MimeType, format) == 0 )
      {
         *pClsid = pImageCodecInfo[j].Clsid;
         free(pImageCodecInfo);
         return j;  // Success
      }    
   }

   free(pImageCodecInfo);
   return -1;  // Failure
}

Top

Tworzenie sieci przetwarzania obrazu

W tej sekcji opisano sposób tworzenia sieci bloków asynchroniczny komunikat przetwarzania obrazu na każdym JPEG obrazu (.jpg) w danym katalogu.Sieci wykonuje następujące operacje przetwarzania obrazu:

1. Dla obrazu, który został utworzony przez Tom Konwertuj na skalę szarości.

2. Dla obrazu, który ma dominujący kolor czerwony usuwanie składników zielonego i niebieskiego i przyciemnić go.

3. Dla innych obrazów zastosowanie sepia tonowania.

Sieci stosuje się tylko pierwsza operacja przetwarzania obrazu, pasujący do jednego z tych warunków.Na przykład jeśli obraz został utworzony przez Tom i ma dominujący kolor czerwony, obraz jest tylko konwertowane na skalę szarości.

Po sieci wykonuje każdej operacji przetwarzania obrazu, zapisuje obraz na dysku jako plik mapy bitowej (.bmp).

Poniższe kroki pokazują jak utworzyć funkcję, która implementuje tej sieci przetwarzania obrazu i stosuje się do sieci w każdej JPEG obrazu w danym katalogu.

Aby utworzyć sieć przetwarzania obrazu

1. Utwórz funkcję, ProcessImages, która pobiera nazwę katalogu na dysku.

   void ProcessImages(const wstring& directory)
   {
   }
   

2. W ProcessImages działać, tworzenie countdown_event zmienna.countdown_event Klasy znajduje się później w tym instruktażu.

   // Holds the number of active image processing operations and  
   // signals to the main thread that processing is complete.
   countdown_event active(0);
   

3. Tworzenie std::map kojarzy obiekt Bitmap obiekt z oryginalną nazwą pliku.

   // Maps Bitmap objects to their original file names.
   map<Bitmap*, wstring> bitmap_file_names;
   

4. Dodaj następujący kod do definiowania członków sieci przetwarzania obrazu.

   // 
   // Create the nodes of the network. 
   // 
   
   // Loads Bitmap objects from disk.
   transformer<wstring, Bitmap*> load_bitmap(
      [&](wstring file_name) -> Bitmap* {
         Bitmap* bmp = new Bitmap(file_name.c_str());
         if (bmp != nullptr)
            bitmap_file_names.insert(make_pair(bmp, file_name));
         return bmp;
      }
   );
   
   // Holds loaded Bitmap objects.
   unbounded_buffer<Bitmap*> loaded_bitmaps;
   
   // Converts images that are authored by Tom to grayscale.
   transformer<Bitmap*, Bitmap*> grayscale(
      [](Bitmap* bmp) {
         return Grayscale(bmp);
      },
      nullptr,
      [](Bitmap* bmp) -> bool {
         if (bmp == nullptr)
            return false;
   
         // Retrieve the artist name from metadata.
         UINT size = bmp->GetPropertyItemSize(PropertyTagArtist);
         if (size == 0)
            // Image does not have the Artist property. 
            return false;
   
         PropertyItem* artistProperty = (PropertyItem*) malloc(size);
         bmp->GetPropertyItem(PropertyTagArtist, size, artistProperty);
         string artist(reinterpret_cast<char*>(artistProperty->value));
         free(artistProperty);
   
         return (artist.find("Tom ") == 0);
      }
   );
   
   // Removes the green and blue color components from images that have red as 
   // their dominant color.
   transformer<Bitmap*, Bitmap*> colormask(
      [](Bitmap* bmp) {
         return ColorMask(bmp, 0x00ff0000);
      },
      nullptr,
      [](Bitmap* bmp) -> bool { 
         if (bmp == nullptr)
            return false;
         return (GetColorDominance(bmp) == 0x00ff0000);
      }
   );
   
   // Darkens the color of the provided Bitmap object.
   transformer<Bitmap*, Bitmap*> darken([](Bitmap* bmp) {
      return Darken(bmp, 50);
   });
   
   // Applies sepia toning to the remaining images.
   transformer<Bitmap*, Bitmap*> sepiatone(
      [](Bitmap* bmp) {
         return Sepiatone(bmp);
      },
      nullptr,
      [](Bitmap* bmp) -> bool { return bmp != nullptr; }
   );
   
   // Saves Bitmap objects to disk.
   transformer<Bitmap*, Bitmap*> save_bitmap([&](Bitmap* bmp) -> Bitmap* {
      // Replace the file extension with .bmp.
      wstring file_name = bitmap_file_names[bmp];
      file_name.replace(file_name.rfind(L'.') + 1, 3, L"bmp");
   
      // Save the processed image.
      CLSID bmpClsid;
      GetEncoderClsid(L"image/bmp", &bmpClsid);      
      bmp->Save(file_name.c_str(), &bmpClsid);
   
      return bmp;
   });
   
   // Deletes Bitmap objects.
   transformer<Bitmap*, Bitmap*> delete_bitmap([](Bitmap* bmp) -> Bitmap* {      
      delete bmp;
      return nullptr;
   });
   
   // Decrements the event counter.
   call<Bitmap*> decrement([&](Bitmap* _) {      
      active.signal();
   });
   

5. Dodaj następujący kod do łączenia się z siecią.

   // 
   // Connect the network. 
   //   
   
   load_bitmap.link_target(&loaded_bitmaps);
   
   loaded_bitmaps.link_target(&grayscale);
   loaded_bitmaps.link_target(&colormask);   
   colormask.link_target(&darken);
   loaded_bitmaps.link_target(&sepiatone);
   loaded_bitmaps.link_target(&decrement);
   
   grayscale.link_target(&save_bitmap);
   darken.link_target(&save_bitmap);
   sepiatone.link_target(&save_bitmap);
   
   save_bitmap.link_target(&delete_bitmap);
   delete_bitmap.link_target(&decrement);
   

6. Dodaj następujący kod do wysyłania do głowy sieci pełną ścieżkę JPEG plik w katalogu.

   // Traverse all files in the directory.
   wstring searchPattern = directory;
   searchPattern.append(L"\\*");
   
   WIN32_FIND_DATA fileFindData;
   HANDLE hFind = FindFirstFile(searchPattern.c_str(), &fileFindData);
   if (hFind == INVALID_HANDLE_VALUE) 
      return;
   do
   {
      if (!(fileFindData.dwFileAttributes & FILE_ATTRIBUTE_DIRECTORY))
      {
         wstring file = fileFindData.cFileName;
   
         // Process only JPEG files. 
         if (file.rfind(L".jpg") == file.length() - 4)
         {
            // Form the full path to the file.
            wstring full_path(directory);
            full_path.append(L"\\");
            full_path.append(file);
   
            // Increment the count of work items.
            active.add_count();
   
            // Send the path name to the network.
            send(load_bitmap, full_path);
         }
      }
   }
   while (FindNextFile(hFind, &fileFindData) != 0); 
   FindClose(hFind);
   

7. Poczekaj, aż countdown_event zmienna, aby osiągnąć zero.

   // Wait for all operations to finish.
   active.wait();
   

W poniższej tabeli opisano członków sieci.

Członkowskie	Opis
load_bitmap	A concurrency::transformer obiekt, który ładuje Bitmap obiekt z dysku i dodaje wpis do map obiekt, aby skojarzyć obrazu z oryginalną nazwą pliku.
loaded_bitmaps	A concurrency::unbounded_buffer obiekt, który wysyła obrazy ładowane filtry przetwarzania obrazów.
grayscale	A transformer obiekt, który konwertuje obrazy, które były edytowane przez Tom na skalę szarości.Używa metadanych obrazu, aby określić jego autora.
colormask	A transformer obiekt, który usuwa składowych koloru zielonego i niebieskiego z obrazów, których dominujący kolor czerwony.
darken	A transformer obiektu przyciemnionym obrazy, których dominujący kolor czerwony.
sepiatone	A transformer obiekt, który dotyczy sepia tonowania obrazy, które nie są tworzone przez Tom i nie są głównie czerwony.
save_bitmap	A transformer obiekt, który zapisuje przetworzone image na dysku jako bitmapę.save_bitmappobiera nazwę oryginalnego pliku z map object i zmienia jego rozszerzenie .bmp.
delete_bitmap	A transformer obiekt, który zwalnia pamięć dla obrazów.
decrement	A concurrency::call obiekt, który działa jako węzeł terminali w sieci.To zmniejsza countdown_event obiektu do sygnalizowania głównej aplikacji, że obraz został przetworzony.

loaded_bitmaps Bufor komunikatów jest ważne, ponieważ jako unbounded_buffer obiektu oferuje Bitmap obiekty do wielu odbiorników.Gdy blok docelowy zaakceptuje Bitmap obiektu, unbounded_buffer obiektu nie dają, że Bitmap obiektu do innych celów.W związku z tym, kolejność, w której obiekty do unbounded_buffer obiekt jest ważne.grayscale, colormask, I sepiatone bloków każdego Użyj filtru, aby zaakceptować wiadomość tylko niektórych Bitmap obiektów.decrement Bufor komunikatów jest ważny cel z loaded_bitmaps komunikat buforu, ponieważ akceptuje wszystkie Bitmap obiektów, które zostały odrzucone przez innych buforów wiadomości.unbounded_buffer Obiektu jest wymagane do propagowania wiadomości w kolejności.W związku z tym unbounded_buffer obiektu blokuje aż nowego bloku docelowego jest połączony i akceptuje wiadomość, jeśli brak bieżącego bloku docelowego akceptuje wiadomości.

Jeśli aplikacja wymaga wielu wiadomości blokuje proces wiadomości, zamiast po prostu bloku jednej wiadomości najpierw akceptuje wiadomości, można użyć innego typu bloku komunikatu, takich jak overwrite_buffer.overwrite_buffer Klasa przechowuje jednej wiadomości w czasie, ale propaguje on tej wiadomości do każdego z jej celów.

Na następującej ilustracji pokazano sieć przetwarzania obrazu:

countdown_event Obiektu w tym przykładzie umożliwia sieć przetwarzania obrazu poinformować głównej aplikacji, gdy wszystkie obrazy zostały przetworzone.countdown_event Klasy zastosowań concurrency::event obiektu do sygnału, gdy wartość licznika osiągnie zero.Głównym aplikacji zwiększa licznik za każdym razem, że wysyła nazwę pliku w sieci.Węzeł terminali Dekrementuje sieci licznika po przetworzeniu każdego obrazu.Po głównej aplikacji przechodzi określony katalog, oczekuje na countdown_event obiekt, aby zasygnalizować, że jego licznik osiągnął zero.

W poniższym przykładzie countdown_event klasy:

// A synchronization primitive that is signaled when its  
// count reaches zero. 
class countdown_event
{
public:
   countdown_event(unsigned int count = 0)
      : _current(static_cast<long>(count)) 
   {
      // Set the event if the initial count is zero. 
      if (_current == 0L)
         _event.set();
   }

   // Decrements the event counter. 
   void signal() {
      if(InterlockedDecrement(&_current) == 0L) {
         _event.set();
      }
   }

   // Increments the event counter. 
   void add_count() {
      if(InterlockedIncrement(&_current) == 1L) {
         _event.reset();
      }
   }

   // Blocks the current context until the event is set. 
   void wait() {
      _event.wait();
   }

private:
   // The current count. 
   volatile long _current;
   // The event that is set when the counter reaches zero. 
   event _event;

   // Disable copy constructor.
   countdown_event(const countdown_event&);
   // Disable assignment.
   countdown_event const & operator=(countdown_event const&);
};

Top

Kompletny przykład

Poniższy kod przedstawia przykład kompletne.wmain Zarządza funkcji GDI+ wywołań i biblioteki ProcessImages funkcji procesu JPEG plików w Przykładowe obrazy katalogu.

// image-processing-network.cpp 
// compile with: /DUNICODE /EHsc image-processing-network.cpp /link gdiplus.lib
#include <windows.h>
#include <gdiplus.h>
#include <iostream>
#include <map>
#include <agents.h>
#include <ppl.h>

using namespace concurrency;
using namespace Gdiplus;
using namespace std;

// Retrieves the red, green, and blue components from the given 
// color value. 
void GetRGB(DWORD color, BYTE& r, BYTE& g, BYTE& b)
{
   r = static_cast<BYTE>((color & 0x00ff0000) >> 16);
   g = static_cast<BYTE>((color & 0x0000ff00) >> 8);
   b = static_cast<BYTE>((color & 0x000000ff));
}

// Creates a single color value from the provided red, green,  
// and blue components.
DWORD MakeColor(BYTE r, BYTE g, BYTE b)
{
   return (r<<16) | (g<<8) | (b);
}

// Calls the provided function for each pixel in a Bitmap object. 
void ProcessImage(Bitmap* bmp, const function<void (DWORD&)>& f)
{
   int width = bmp->GetWidth();
   int height = bmp->GetHeight();

   // Lock the bitmap.
   BitmapData bitmapData;
   Rect rect(0, 0, bmp->GetWidth(), bmp->GetHeight());
   bmp->LockBits(&rect, ImageLockModeWrite, PixelFormat32bppRGB, &bitmapData);

   // Get a pointer to the bitmap data.
   DWORD* image_bits = (DWORD*)bitmapData.Scan0;

   // Call the function for each pixel in the image.
   parallel_for (0, height, [&, width](int y)
   {      
      for (int x = 0; x < width; ++x)
      {
         // Get the current pixel value.
         DWORD* curr_pixel = image_bits + (y * width) + x;

         // Call the function.
         f(*curr_pixel);
      }
   });

   // Unlock the bitmap.
   bmp->UnlockBits(&bitmapData);
}

// Converts the given image to grayscale.
Bitmap* Grayscale(Bitmap* bmp) 
{
   ProcessImage(bmp, 
      [](DWORD& color) {
         BYTE r, g, b;
         GetRGB(color, r, g, b);

         // Set each color component to the average of  
         // the original components.
         BYTE c = (static_cast<WORD>(r) + g + b) / 3;
         color = MakeColor(c, c, c);
      }
   );
   return bmp;
}

// Applies sepia toning to the provided image.
Bitmap* Sepiatone(Bitmap* bmp) 
{
   ProcessImage(bmp, 
      [](DWORD& color) {
         BYTE r0, g0, b0;
         GetRGB(color, r0, g0, b0);

         WORD r1 = static_cast<WORD>((r0 * .393) + (g0 *.769) + (b0 * .189));
         WORD g1 = static_cast<WORD>((r0 * .349) + (g0 *.686) + (b0 * .168));
         WORD b1 = static_cast<WORD>((r0 * .272) + (g0 *.534) + (b0 * .131));

         color = MakeColor(min(0xff, r1), min(0xff, g1), min(0xff, b1));
      }
   );
   return bmp;
}

// Applies the given color mask to each pixel in the provided image.
Bitmap* ColorMask(Bitmap* bmp, DWORD mask)
{
   ProcessImage(bmp, 
      [mask](DWORD& color) {
         color = color & mask;
      }
   );
   return bmp;
}

// Darkens the provided image by the given amount.
Bitmap* Darken(Bitmap* bmp, unsigned int percent)
{
   if (percent > 100)
      throw invalid_argument("Darken: percent must less than 100.");

   double factor = percent / 100.0;

   ProcessImage(bmp, 
      [factor](DWORD& color) {
         BYTE r, g, b;
         GetRGB(color, r, g, b);
         r = static_cast<BYTE>(factor*r);
         g = static_cast<BYTE>(factor*g);
         b = static_cast<BYTE>(factor*b);
         color = MakeColor(r, g, b);
      }
   );
   return bmp;
}

// Determines which color component (red, green, or blue) is most dominant 
// in the given image and returns a corresponding color mask.
DWORD GetColorDominance(Bitmap* bmp)
{
   // The ProcessImage function processes the image in parallel. 
   // The following combinable objects enable the callback function 
   // to increment the color counts without using a lock.
   combinable<unsigned int> reds;
   combinable<unsigned int> greens;
   combinable<unsigned int> blues;

   ProcessImage(bmp, 
      [&](DWORD& color) {
         BYTE r, g, b;
         GetRGB(color, r, g, b);
         if (r >= g && r >= b)
            reds.local()++;
         else if (g >= r && g >= b)
            greens.local()++;
         else
            blues.local()++;
      }
   );

   // Determine which color is dominant and return the corresponding 
   // color mask. 

   unsigned int r = reds.combine(plus<unsigned int>());
   unsigned int g = greens.combine(plus<unsigned int>());
   unsigned int b = blues.combine(plus<unsigned int>());

   if (r + r >= g + b)
      return 0x00ff0000;
   else if (g + g >= r + b)
      return 0x0000ff00;
   else 
      return 0x000000ff;
}

// Retrieves the class identifier for the given MIME type of an encoder. 
int GetEncoderClsid(const WCHAR* format, CLSID* pClsid)
{
   UINT  num = 0;          // number of image encoders
   UINT  size = 0;         // size of the image encoder array in bytes

   ImageCodecInfo* pImageCodecInfo = nullptr;

   GetImageEncodersSize(&num, &size);
   if(size == 0)
      return -1;  // Failure

   pImageCodecInfo = (ImageCodecInfo*)(malloc(size));
   if(pImageCodecInfo == nullptr)
      return -1;  // Failure

   GetImageEncoders(num, size, pImageCodecInfo);

   for(UINT j = 0; j < num; ++j)
   {
      if( wcscmp(pImageCodecInfo[j].MimeType, format) == 0 )
      {
         *pClsid = pImageCodecInfo[j].Clsid;
         free(pImageCodecInfo);
         return j;  // Success
      }    
   }

   free(pImageCodecInfo);
   return -1;  // Failure
}

// A synchronization primitive that is signaled when its  
// count reaches zero. 
class countdown_event
{
public:
   countdown_event(unsigned int count = 0)
      : _current(static_cast<long>(count)) 
   {
      // Set the event if the initial count is zero. 
      if (_current == 0L)
         _event.set();
   }

   // Decrements the event counter. 
   void signal() {
      if(InterlockedDecrement(&_current) == 0L) {
         _event.set();
      }
   }

   // Increments the event counter. 
   void add_count() {
      if(InterlockedIncrement(&_current) == 1L) {
         _event.reset();
      }
   }

   // Blocks the current context until the event is set. 
   void wait() {
      _event.wait();
   }

private:
   // The current count. 
   volatile long _current;
   // The event that is set when the counter reaches zero. 
   event _event;

   // Disable copy constructor.
   countdown_event(const countdown_event&);
   // Disable assignment.
   countdown_event const & operator=(countdown_event const&);
};

// Demonstrates how to set up a message network that performs a series of  
// image processing operations on each JPEG image in the given directory and 
// saves each altered image as a Windows bitmap. 
void ProcessImages(const wstring& directory)
{
   // Holds the number of active image processing operations and  
   // signals to the main thread that processing is complete.
   countdown_event active(0);

   // Maps Bitmap objects to their original file names.
   map<Bitmap*, wstring> bitmap_file_names;

   // 
   // Create the nodes of the network. 
   // 

   // Loads Bitmap objects from disk.
   transformer<wstring, Bitmap*> load_bitmap(
      [&](wstring file_name) -> Bitmap* {
         Bitmap* bmp = new Bitmap(file_name.c_str());
         if (bmp != nullptr)
            bitmap_file_names.insert(make_pair(bmp, file_name));
         return bmp;
      }
   );

   // Holds loaded Bitmap objects.
   unbounded_buffer<Bitmap*> loaded_bitmaps;

   // Converts images that are authored by Tom to grayscale.
   transformer<Bitmap*, Bitmap*> grayscale(
      [](Bitmap* bmp) {
         return Grayscale(bmp);
      },
      nullptr,
      [](Bitmap* bmp) -> bool {
         if (bmp == nullptr)
            return false;

         // Retrieve the artist name from metadata.
         UINT size = bmp->GetPropertyItemSize(PropertyTagArtist);
         if (size == 0)
            // Image does not have the Artist property. 
            return false;

         PropertyItem* artistProperty = (PropertyItem*) malloc(size);
         bmp->GetPropertyItem(PropertyTagArtist, size, artistProperty);
         string artist(reinterpret_cast<char*>(artistProperty->value));
         free(artistProperty);

         return (artist.find("Tom ") == 0);
      }
   );

   // Removes the green and blue color components from images that have red as 
   // their dominant color.
   transformer<Bitmap*, Bitmap*> colormask(
      [](Bitmap* bmp) {
         return ColorMask(bmp, 0x00ff0000);
      },
      nullptr,
      [](Bitmap* bmp) -> bool { 
         if (bmp == nullptr)
            return false;
         return (GetColorDominance(bmp) == 0x00ff0000);
      }
   );

   // Darkens the color of the provided Bitmap object.
   transformer<Bitmap*, Bitmap*> darken([](Bitmap* bmp) {
      return Darken(bmp, 50);
   });

   // Applies sepia toning to the remaining images.
   transformer<Bitmap*, Bitmap*> sepiatone(
      [](Bitmap* bmp) {
         return Sepiatone(bmp);
      },
      nullptr,
      [](Bitmap* bmp) -> bool { return bmp != nullptr; }
   );

   // Saves Bitmap objects to disk.
   transformer<Bitmap*, Bitmap*> save_bitmap([&](Bitmap* bmp) -> Bitmap* {
      // Replace the file extension with .bmp.
      wstring file_name = bitmap_file_names[bmp];
      file_name.replace(file_name.rfind(L'.') + 1, 3, L"bmp");

      // Save the processed image.
      CLSID bmpClsid;
      GetEncoderClsid(L"image/bmp", &bmpClsid);      
      bmp->Save(file_name.c_str(), &bmpClsid);

      return bmp;
   });

   // Deletes Bitmap objects.
   transformer<Bitmap*, Bitmap*> delete_bitmap([](Bitmap* bmp) -> Bitmap* {      
      delete bmp;
      return nullptr;
   });

   // Decrements the event counter.
   call<Bitmap*> decrement([&](Bitmap* _) {      
      active.signal();
   });

   // 
   // Connect the network. 
   //   

   load_bitmap.link_target(&loaded_bitmaps);

   loaded_bitmaps.link_target(&grayscale);
   loaded_bitmaps.link_target(&colormask);   
   colormask.link_target(&darken);
   loaded_bitmaps.link_target(&sepiatone);
   loaded_bitmaps.link_target(&decrement);

   grayscale.link_target(&save_bitmap);
   darken.link_target(&save_bitmap);
   sepiatone.link_target(&save_bitmap);

   save_bitmap.link_target(&delete_bitmap);
   delete_bitmap.link_target(&decrement);

   // Traverse all files in the directory.
   wstring searchPattern = directory;
   searchPattern.append(L"\\*");

   WIN32_FIND_DATA fileFindData;
   HANDLE hFind = FindFirstFile(searchPattern.c_str(), &fileFindData);
   if (hFind == INVALID_HANDLE_VALUE) 
      return;
   do
   {
      if (!(fileFindData.dwFileAttributes & FILE_ATTRIBUTE_DIRECTORY))
      {
         wstring file = fileFindData.cFileName;

         // Process only JPEG files. 
         if (file.rfind(L".jpg") == file.length() - 4)
         {
            // Form the full path to the file.
            wstring full_path(directory);
            full_path.append(L"\\");
            full_path.append(file);

            // Increment the count of work items.
            active.add_count();

            // Send the path name to the network.
            send(load_bitmap, full_path);
         }
      }
   }
   while (FindNextFile(hFind, &fileFindData) != 0); 
   FindClose(hFind);

   // Wait for all operations to finish.
   active.wait();
}

int wmain()
{
   GdiplusStartupInput gdiplusStartupInput;
   ULONG_PTR           gdiplusToken;

   // Initialize GDI+.
   GdiplusStartup(&gdiplusToken, &gdiplusStartupInput, nullptr);

   // Perform image processing. 
   // TODO: Change this path if necessary.
   ProcessImages(L"C:\\Users\\Public\\Pictures\\Sample Pictures");

   // Shutdown GDI+.
   GdiplusShutdown(gdiplusToken);
}

Na następującej ilustracji pokazano przykładowe dane wyjściowe.Każdy obraz źródłowy jest powyżej jej odpowiednie zmodyfikowany obraz.

Latarnia morska został utworzony przez Tom Alphin i dlatego jest konwertowane na skalę szarości.Chrysanthemum, Desert, Koala, i Tulipany ma dominujący kolor czerwony i dlatego składników koloru niebieskiego i zielonego, usuwane i są przyciemniane.Hydrangeas, Jellyfish, i Penguins spełniają kryteria domyślne, dlatego sepia toned.

Top

Kompilowanie kodu

Skopiuj przykładowy kod i wklej go w projekcie programu Visual Studio lub wkleić go w pliku o nazwie obrazu z przetwarzania network.cpp , a następnie uruchom następujące polecenie w oknie wiersza polecenia usługi programu Visual Studio.

cl.exe /DUNICODE /EHsc image-processing-network.cpp /link gdiplus.lib

Zobacz też

Inne zasoby

Współbieżność środowiska wykonawczego — Wskazówki